trushev commented on PR #20314:
URL: https://github.com/apache/flink/pull/20314#issuecomment-1189849073
@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.
Yanfei Lei created FLINK-28614:
--
Summary: Empty local state folders not cleanup on retrieving local
state
Key: FLINK-28614
URL: https://issues.apache.org/jira/browse/FLINK-28614
Project: Flink
reswqa commented on code in PR #20306:
URL: https://github.com/apache/flink/pull/20306#discussion_r925151253
##
flink-dstl/flink-dstl-dfs/src/test/java/org/apache/flink/changelog/fs/StateChangeFsUploaderTest.java:
##
@@ -19,18 +19,32 @@
package org.apache.flink.changelog.fs;
TanYuxin-tyx commented on PR #20308:
URL: https://github.com/apache/flink/pull/20308#issuecomment-1189785395
@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
JingsongLi merged PR #229:
URL: https://github.com/apache/flink-table-store/pull/229
--
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:
flinkbot commented on PR #20314:
URL: https://github.com/apache/flink/pull/20314#issuecomment-1189780215
## CI report:
* 32e07a9d01a177f4586de8c1a0bd99ad054d708d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
fsk119 commented on code in PR #20101:
URL: https://github.com/apache/flink/pull/20101#discussion_r925140186
##
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/context/SessionContext.java:
##
@@ -157,10 +148,39 @@ public synchronized void
trushev opened a new pull request, #20314:
URL: https://github.com/apache/flink/pull/20314
## What is the purpose of the change
I believe `com.sun.istack.NotNull` was accidentally used instead of
`org.jetbrains.annotations.NotNull` in testuils
```
$ grep -rw . -e 'import
fredia closed pull request #20291: don't delay the deletion of checkpoints of
incremental rocksdb
URL: https://github.com/apache/flink/pull/20291
--
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
wuchong commented on PR #19989:
URL: https://github.com/apache/flink/pull/19989#issuecomment-1189765626
Looks good to me. @luoyuxia could you rebase the branch and resolve the
conflicts?
--
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-27655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-27655.
Resolution: Invalid
> Implement Avro File statistic collector
>
[
https://issues.apache.org/jira/browse/FLINK-27655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17568800#comment-17568800
]
Jingsong Lee commented on FLINK-27655:
--
Avro dose not provide statistics.
> Implement Avro File
[
https://issues.apache.org/jira/browse/FLINK-28184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-28184.
Resolution: Fixed
> LogStoreE2eTest is not stable
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-27679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-27679:
-
Parent: (was: FLINK-27307)
Issue Type: Bug (was: Sub-task)
> Add tests for
[
https://issues.apache.org/jira/browse/FLINK-27307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-27307.
Resolution: Fixed
> Flink table store support append-only ingestion without primary keys.
>
fredia commented on code in PR #20313:
URL: https://github.com/apache/flink/pull/20313#discussion_r925114799
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistryImpl.java:
##
@@ -162,7 +174,14 @@ public Set unregisterUnusedState(long
[
https://issues.apache.org/jira/browse/FLINK-28535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-28535:
-
Priority: Minor (was: Major)
> Support create namespace/table for SparkCatalog
>
[
https://issues.apache.org/jira/browse/FLINK-27679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-27679:
-
Summary: Add tests for append-only table with log store (was: Support
append-only table for
[
https://issues.apache.org/jira/browse/FLINK-28458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-28458.
Resolution: Fixed
master: 81eb8830e22b0e8411fbc9296229d0e8a3343a0e
> Document append-only mode
>
JingsongLi merged PR #228:
URL: https://github.com/apache/flink-table-store/pull/228
--
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:
weibozhao commented on code in PR #131:
URL: https://github.com/apache/flink-ml/pull/131#discussion_r925115735
##
flink-ml-core/src/main/java/org/apache/flink/ml/param/ParamValidators.java:
##
@@ -38,6 +38,22 @@ public static ParamValidator gtEq(double lowerBound) {
weibozhao commented on code in PR #131:
URL: https://github.com/apache/flink-ml/pull/131#discussion_r925115735
##
flink-ml-core/src/main/java/org/apache/flink/ml/param/ParamValidators.java:
##
@@ -38,6 +38,22 @@ public static ParamValidator gtEq(double lowerBound) {
lincoln-lil commented on code in PR #20242:
URL: https://github.com/apache/flink/pull/20242#discussion_r925114125
##
flink-table/flink-sql-parser/src/main/codegen/includes/parserImpls.ftl:
##
@@ -2203,3 +2203,94 @@ SqlNode TryCastFunctionCall() :
return
wuchong merged PR #20309:
URL: https://github.com/apache/flink/pull/20309
--
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:
JingsongLi commented on code in PR #228:
URL: https://github.com/apache/flink-table-store/pull/228#discussion_r925107204
##
docs/content/docs/development/create-table.md:
##
@@ -166,10 +166,38 @@ Partitioned filtering is the most effective way to
improve performance,
your
Sxnan commented on PR #20147:
URL: https://github.com/apache/flink/pull/20147#issuecomment-1189737080
@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.
JingsongLi closed pull request #19794: [hotfix] Fix document in
Catalog.supportsManagedTable
URL: https://github.com/apache/flink/pull/19794
--
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
leozhangsr commented on code in PR #20234:
URL: https://github.com/apache/flink/pull/20234#discussion_r925103325
##
flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/split/KafkaPartitionSplitSerializerTest.java:
##
@@ -0,0 +1,54 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-27523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin resolved FLINK-27523.
--
Resolution: Fixed
> Runtime supports producing and consuming cached intermediate result
>
[
https://issues.apache.org/jira/browse/FLINK-27524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin reassigned FLINK-27524:
Assignee: Xuannan Su
> Introduce cache API to DataStream
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-27523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin reassigned FLINK-27523:
Assignee: Xuannan Su
> Runtime supports producing and consuming cached intermediate result
>
1996fanrui commented on PR #20233:
URL: https://github.com/apache/flink/pull/20233#issuecomment-1189732263
@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
lincoln-lil commented on PR #20309:
URL: https://github.com/apache/flink/pull/20309#issuecomment-1189725263
LGTM! +1
--
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-15289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-15289:
---
Assignee: Jark Wu
> Run sql appear error of "Zero-length character strings have no serializable
>
[
https://issues.apache.org/jira/browse/FLINK-15289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-15289:
Fix Version/s: 1.16.0
> Run sql appear error of "Zero-length character strings have no serializable
>
fsk119 commented on code in PR #20159:
URL: https://github.com/apache/flink/pull/20159#discussion_r925095048
##
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/LocalExecutor.java:
##
@@ -322,4 +339,96 @@ public List listJars(String
lsyldliu commented on PR #20001:
URL: https://github.com/apache/flink/pull/20001#issuecomment-1189711920
@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
yunfengzhou-hub commented on code in PR #131:
URL: https://github.com/apache/flink-ml/pull/131#discussion_r925083352
##
flink-ml-core/src/main/java/org/apache/flink/ml/param/ParamValidators.java:
##
@@ -38,6 +38,22 @@ public static ParamValidator gtEq(double lowerBound) {
godfreyhe commented on PR #20243:
URL: https://github.com/apache/flink/pull/20243#issuecomment-1189706693
@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
yunfengzhou-hub commented on PR #130:
URL: https://github.com/apache/flink-ml/pull/130#issuecomment-1189696621
Thanks for the update. It LGTM now.
--
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
mas-chen commented on code in PR #20164:
URL: https://github.com/apache/flink/pull/20164#discussion_r925068981
##
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaRecordSerializationSchema.java:
##
@@ -48,6 +48,12 @@ default void
mas-chen commented on code in PR #20234:
URL: https://github.com/apache/flink/pull/20234#discussion_r925038355
##
flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/reader/KafkaPartitionSplitReaderTest.java:
##
@@ -84,6 +85,7 @@ public
sunshineJK commented on PR #20127:
URL: https://github.com/apache/flink/pull/20127#issuecomment-1189661563
Hi @afedulov @MartijnVisser @PatrickRen What are the next steps? Do I need
to do any more operations
--
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-24119:
---
Labels: stale-critical test-stability (was: test-stability)
I am the [Flink Jira
[
https://issues.apache.org/jira/browse/FLINK-26402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-26402:
---
Labels: pull-request-available stale-critical test-stability (was:
pull-request-available
[
https://issues.apache.org/jira/browse/FLINK-28395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-28395:
---
Labels: stale-critical test-stability (was: test-stability)
I am the [Flink Jira
JingGe commented on code in PR #20140:
URL: https://github.com/apache/flink/pull/20140#discussion_r924934341
##
flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcFilterPushdownVisitor.java:
##
@@ -53,7 +52,6 @@
* Visitor to walk a
JingGe commented on code in PR #20140:
URL: https://github.com/apache/flink/pull/20140#discussion_r924934341
##
flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcFilterPushdownVisitor.java:
##
@@ -53,7 +52,6 @@
* Visitor to walk a
MartijnVisser commented on code in PR #20140:
URL: https://github.com/apache/flink/pull/20140#discussion_r924911685
##
flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcFilterPushdownVisitor.java:
##
@@ -53,7 +52,6 @@
* Visitor to
rkhachatryan commented on PR #20091:
URL: https://github.com/apache/flink/pull/20091#issuecomment-1189495948
I have added a couple of fixup commits on top of this PR changes:
https://github.com/rkhachatryan/flink/tree/f27570-exception
Would you mind picking them (unless you have
qingwei91 commented on code in PR #20140:
URL: https://github.com/apache/flink/pull/20140#discussion_r924891272
##
flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcFilterPushdownVisitor.java:
##
@@ -53,7 +52,6 @@
* Visitor to walk
qingwei91 commented on code in PR #20235:
URL: https://github.com/apache/flink/pull/20235#discussion_r924890763
##
flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/dialect/sqlserver/SqlServerPreparedStatementTest.java:
##
@@ -0,0 +1,93 @@
+/*
rkhachatryan commented on PR #20091:
URL: https://github.com/apache/flink/pull/20091#issuecomment-1189475857
AZP failure unrelated: FLINK-28269
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to
[
https://issues.apache.org/jira/browse/FLINK-27570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan updated FLINK-27570:
--
Priority: Major (was: Critical)
> Checkpoint path error does not cause the job to
afedulov commented on PR #20049:
URL: https://github.com/apache/flink/pull/20049#issuecomment-1189456851
Update: this effort is currently pending the introduction of the FLIP-238
data generation sources.
--
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/FLINK-28613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Clive Wong resolved FLINK-28613.
Resolution: Workaround
> PyFlink 1.15 unable to start in Application Mode in k8s
>
[
https://issues.apache.org/jira/browse/FLINK-28613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17568685#comment-17568685
]
Clive Wong commented on FLINK-28613:
Turns out it's because of this change:
MartijnVisser commented on PR #14376:
URL: https://github.com/apache/flink/pull/14376#issuecomment-1189337469
@maosuhan You'll need to add `com.google.protobuf:protobuf-java:3.21.2` to
the NOTICE file for `flink-sql-protobuf`
--
This is an automated message from the Apache Git Service.
flinkbot commented on PR #20313:
URL: https://github.com/apache/flink/pull/20313#issuecomment-1189312666
## CI report:
* 815fc355232f40adb363bf55031ffb942e7f8a78 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
rkhachatryan opened a new pull request, #20313:
URL: https://github.com/apache/flink/pull/20313
## What is the purpose of the change
This PR limits checkpoint discard delay in CLAIM restore mode to two cases:
1. Changelog (off -> on). Adjust `SharedStateRegsitry` API to make it
[
https://issues.apache.org/jira/browse/FLINK-28613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Clive Wong updated FLINK-28613:
---
Description:
I recently bumped my PyFlink job from 1.14 to 1.15, and the job is failing with
build
reswqa commented on code in PR #20293:
URL: https://github.com/apache/flink/pull/20293#discussion_r924687852
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsMemoryDataManager.java:
##
@@ -0,0 +1,673 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-28223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-28223:
---
Fix Version/s: kubernetes-operator-1.2.0
> Add artifact-fetcher to the pod-template.yaml example
>
[
https://issues.apache.org/jira/browse/FLINK-28223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-28223:
---
Affects Version/s: (was: kubernetes-operator-1.1.0)
> Add artifact-fetcher to the
gyfora commented on PR #314:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/314#issuecomment-1189204455
@darenwkt I think we can close this PR for now based on the offline
discussions
--
This is an automated message from the Apache Git Service.
To respond to the message,
[
https://issues.apache.org/jira/browse/FLINK-28207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-28207.
--
Resolution: Fixed
merged to main a2908f5b773573fe2b76dd6061512a27f698ec4f
> Disabling webhook should
gyfora merged PR #323:
URL: https://github.com/apache/flink-kubernetes-operator/pull/323
--
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:
reswqa commented on code in PR #20293:
URL: https://github.com/apache/flink/pull/20293#discussion_r924647096
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsMemoryDataManager.java:
##
@@ -0,0 +1,673 @@
+/*
+ * Licensed to the Apache
reswqa commented on code in PR #20293:
URL: https://github.com/apache/flink/pull/20293#discussion_r924646640
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsMemoryDataManager.java:
##
@@ -0,0 +1,673 @@
+/*
+ * Licensed to the Apache
reswqa commented on code in PR #20293:
URL: https://github.com/apache/flink/pull/20293#discussion_r924645809
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsMemoryDataManager.java:
##
@@ -0,0 +1,673 @@
+/*
+ * Licensed to the Apache
gyfora commented on code in PR #323:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/323#discussion_r924644841
##
helm/flink-kubernetes-operator/values.yaml:
##
@@ -83,8 +83,10 @@ webhookSecurityContext: {}
webhook:
create: true
- mutator:
-create:
morhidi commented on PR #323:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/323#issuecomment-1189180965
+1 LGTM, tested locally
--
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
morhidi commented on code in PR #323:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/323#discussion_r924632811
##
helm/flink-kubernetes-operator/values.yaml:
##
@@ -83,8 +83,10 @@ webhookSecurityContext: {}
webhook:
create: true
- mutator:
-create:
[
https://issues.apache.org/jira/browse/FLINK-28521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17568600#comment-17568600
]
Jean-Damien HATZENBUHLER commented on FLINK-28521:
--
It make sense to skip hostname
[
https://issues.apache.org/jira/browse/FLINK-28521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jean-Damien HATZENBUHLER updated FLINK-28521:
-
Description:
The hostname certificate is not check in ssl context.
[
https://issues.apache.org/jira/browse/FLINK-28521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-28521:
--
Assignee: Jean-Damien HATZENBUHLER
> Hostname verification in ssl context is not
[
https://issues.apache.org/jira/browse/FLINK-28520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-28520:
--
Assignee: Jean-Damien HATZENBUHLER
> RestClient doesn't use SNI TLS extension
>
reswqa commented on code in PR #20293:
URL: https://github.com/apache/flink/pull/20293#discussion_r924610288
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsMemoryDataManager.java:
##
@@ -0,0 +1,673 @@
+/*
+ * Licensed to the Apache
reswqa commented on code in PR #20293:
URL: https://github.com/apache/flink/pull/20293#discussion_r924600342
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsMemoryDataManager.java:
##
@@ -0,0 +1,673 @@
+/*
+ * Licensed to the Apache
link3280 commented on code in PR #20159:
URL: https://github.com/apache/flink/pull/20159#discussion_r924595473
##
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/LocalExecutor.java:
##
@@ -322,4 +339,96 @@ public List listJars(String
link3280 commented on code in PR #20159:
URL: https://github.com/apache/flink/pull/20159#discussion_r924224755
##
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/LocalExecutor.java:
##
@@ -322,4 +339,96 @@ public List listJars(String
[
https://issues.apache.org/jira/browse/FLINK-27447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-27447.
--
Resolution: Won't Fix
This is already covered by the operator logic
> Implement last-state with
[
https://issues.apache.org/jira/browse/FLINK-28113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-28113.
--
Resolution: Fixed
> Document periodic savepointing
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-28521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17568586#comment-17568586
]
Chesnay Schepler commented on FLINK-28521:
--
Seems intentional that we skip hostname
wuchong commented on PR #20309:
URL: https://github.com/apache/flink/pull/20309#issuecomment-1189117044
cc @lincoln-lil
--
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
1996fanrui commented on PR #20233:
URL: https://github.com/apache/flink/pull/20233#issuecomment-1189094363
@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
lindong28 merged PR #129:
URL: https://github.com/apache/flink-ml/pull/129
--
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:
lindong28 commented on PR #129:
URL: https://github.com/apache/flink-ml/pull/129#issuecomment-1189089858
Thanks for the update. 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
[
https://issues.apache.org/jira/browse/FLINK-28411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer reassigned FLINK-28411:
-
Assignee: Daren Wong
> OperatorCoordinator exception may fail Session Cluster
>
[
https://issues.apache.org/jira/browse/FLINK-24932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17568556#comment-17568556
]
Sebastian Mattheis edited comment on FLINK-24932 at 7/19/22 1:40 PM:
-
link3280 commented on code in PR #20101:
URL: https://github.com/apache/flink/pull/20101#discussion_r924392099
##
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/endpoint/hive/HiveServer2EndpointConfigOptions.java:
##
@@ -0,0 +1,119 @@
+/*
+ *
hlteoh37 commented on code in PR #20245:
URL: https://github.com/apache/flink/pull/20245#discussion_r924509131
##
flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/sink/writer/AsyncSinkWriterTest.java:
##
@@ -19,6 +19,8 @@
import
Clive Wong created FLINK-28613:
--
Summary: PyFlink 1.15 unable to start in Application Mode in k8s
Key: FLINK-28613
URL: https://issues.apache.org/jira/browse/FLINK-28613
Project: Flink
Issue
fsk119 closed pull request #20302: [hotfix][table-runtime] Avoid NPE for
SliceAssigner and improve error message
URL: https://github.com/apache/flink/pull/20302
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
hlteoh37 commented on code in PR #20245:
URL: https://github.com/apache/flink/pull/20245#discussion_r924493155
##
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/AsyncSinkWriter.java:
##
@@ -344,69 +351,69 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-24932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17568556#comment-17568556
]
Sebastian Mattheis commented on FLINK-24932:
[~yunta] In theory it would be best to test it,
godfreyhe commented on PR #20243:
URL: https://github.com/apache/flink/pull/20243#issuecomment-1189039700
Thanks for the review, I will rebase the master and squash the commit. I
will merge the pr once it turns green
--
This is an automated message from the Apache Git Service.
To respond
[
https://issues.apache.org/jira/browse/FLINK-28490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he closed FLINK-28490.
--
Resolution: Fixed
Fixed in master: e54c86415b106f253b58c54670fe5b84b5c40f25
> Introduce "ANALYZE
godfreyhe closed pull request #20242: [FLINK-28490][sql-parser] Introduce
`ANALYZE TABLE` syntax in sql parser
URL: https://github.com/apache/flink/pull/20242
--
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
godfreyhe commented on PR #20242:
URL: https://github.com/apache/flink/pull/20242#issuecomment-1189019390
I will merge the 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 to go to the specific
1 - 100 of 253 matches
Mail list logo
