kgrimsby commented on PR #20685:
URL: https://github.com/apache/flink/pull/20685#issuecomment-1257563464
Hi, doesn't this commit introduce a bug?
I've tried to setup from flink release-1.16 branch and found that the
changes in `pyflink/fn_execution/flink_fn_execution_pb2.py` at `DESCR
[
https://issues.apache.org/jira/browse/FLINK-29315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17609324#comment-17609324
]
Matthias Pohl commented on FLINK-29315:
---
Great. Thanks for solving it. [~wangyang0
morhidi commented on PR #384:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/384#issuecomment-1257554675
+1 Thanks, Gyula. I have the feeling though that on long term we should rely
on a more consistent state-machine model, instead of introducing new
states/substates in util
Yun Tang created FLINK-29410:
Summary: Add checks to guarantee the non-deprecated options not
conflicting with standard YAML
Key: FLINK-29410
URL: https://issues.apache.org/jira/browse/FLINK-29410
Project
[
https://issues.apache.org/jira/browse/FLINK-28131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-28131.
---
Release Note:
Speculative execution(FLIP-168) is introduced in Flink 1.16 to mitigate batch
job slowness wh
[
https://issues.apache.org/jira/browse/FLINK-28131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reopened FLINK-28131:
-
> FLIP-168: Speculative Execution for Batch Job
> -
>
>
fsk119 commented on PR #20891:
URL: https://github.com/apache/flink/pull/20891#issuecomment-1257528078
@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
pvary commented on code in PR #382:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/382#discussion_r979582956
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/JobStatusObserver.java:
##
@@ -72,22 +81,92 @@ public boolean obs
[
https://issues.apache.org/jira/browse/FLINK-29402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17609298#comment-17609298
]
Donatien commented on FLINK-29402:
--
Indeed, with RocksDB API it is easy to add this new
[
https://issues.apache.org/jira/browse/FLINK-29020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-29020:
---
Assignee: tartarus
> Add document for CTAS feature
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-29020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17609297#comment-17609297
]
Jark Wu commented on FLINK-29020:
-
Fixed in
- master: 8ce056c59439c1a3cedd6b32c0a98a14
wuchong merged PR #20653:
URL: https://github.com/apache/flink/pull/20653
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.apach
wangyang0918 closed pull request #20879: Debug CI
URL: https://github.com/apache/flink/pull/20879
--
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
[
https://issues.apache.org/jira/browse/FLINK-29409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29409:
---
Labels: pull-request-available (was: )
> Add Transformer and Estimator for VarianceThreshol
jiangxin369 opened a new pull request, #158:
URL: https://github.com/apache/flink-ml/pull/158
## What is the purpose of the change
Adding Transformer and Estimator for VarianceThresholdSelector
## Brief change log
- Added java/python source/test/example for Tran
Jiang Xin created FLINK-29409:
-
Summary: Add Transformer and Estimator for
VarianceThresholdSelector
Key: FLINK-29409
URL: https://issues.apache.org/jira/browse/FLINK-29409
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-29272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-29272:
-
Fix Version/s: (was: table-store-0.2.1)
> Document DataStream API (DataStream to Table) for
xintongsong closed pull request #20857: [hotfix] Fix the problem that
BatchShuffleItCase not subject to configuration.
URL: https://github.com/apache/flink/pull/20857
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
UR
[
https://issues.apache.org/jira/browse/FLINK-29406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee updated FLINK-29406:
Affects Version/s: 1.14.5
> Expose Finish Method For TableFunction
> -
[
https://issues.apache.org/jira/browse/FLINK-29315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo resolved FLINK-29315.
--
Resolution: Fixed
> HDFSTest#testBlobServerRecovery fails on CI
>
[
https://issues.apache.org/jira/browse/FLINK-29315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17609282#comment-17609282
]
Huang Xingbo commented on FLINK-29315:
--
After upgrading the kernel version, this te
flinkbot commented on PR #20898:
URL: https://github.com/apache/flink/pull/20898#issuecomment-1257419037
## CI report:
* 2ec2c1645096c01744e1bd7c19fe6535063ee687 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
zezaeoh commented on code in PR #377:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/377#discussion_r979518665
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractFlinkResourceReconciler.java:
##
@@ -426,4
[
https://issues.apache.org/jira/browse/FLINK-29349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29349:
---
Labels: pull-request-available (was: )
> Use state ttl instead of timer to clean up state i
lincoln-lil opened a new pull request, #20898:
URL: https://github.com/apache/flink/pull/20898
## What is the purpose of the change
Currently we rely on the timer based state cleaning in proctime unbounded
over aggregate, this can be optimized to use state ttl for a more efficienct way
wangyang0918 commented on code in PR #383:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/383#discussion_r979525831
##
flink-kubernetes-operator/pom.xml:
##
@@ -47,6 +47,20 @@ under the License.
io.fabric8
kubernetes-client
[
https://issues.apache.org/jira/browse/FLINK-29402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17609277#comment-17609277
]
Yanfei Lei edited comment on FLINK-29402 at 9/26/22 3:05 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-29402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17609277#comment-17609277
]
Yanfei Lei commented on FLINK-29402:
This is a very interesting proposal, I think th
Huang Xingbo created FLINK-29408:
Summary: HiveCatalogITCase failed with NPE
Key: FLINK-29408
URL: https://issues.apache.org/jira/browse/FLINK-29408
Project: Flink
Issue Type: Bug
C
[
https://issues.apache.org/jira/browse/FLINK-29387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17609276#comment-17609276
]
Huang Xingbo commented on FLINK-29387:
--
https://dev.azure.com/apache-flink/apache-f
xintongsong commented on PR #20857:
URL: https://github.com/apache/flink/pull/20857#issuecomment-1257406264
@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-28898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17609275#comment-17609275
]
Huang Xingbo commented on FLINK-28898:
--
https://dev.azure.com/apache-flink/apache-f
Huang Xingbo created FLINK-29407:
Summary: HiveCatalogITCase.testCsvTableViaSQL failed with
FileNotFoundException
Key: FLINK-29407
URL: https://issues.apache.org/jira/browse/FLINK-29407
Project: Flink
zezaeoh commented on code in PR #377:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/377#discussion_r979518665
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractFlinkResourceReconciler.java:
##
@@ -426,4
[
https://issues.apache.org/jira/browse/FLINK-29405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17609272#comment-17609272
]
Huang Xingbo commented on FLINK-29405:
--
[~smiralex][~renqs] Could you help take a l
[
https://issues.apache.org/jira/browse/FLINK-29405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo updated FLINK-29405:
-
Priority: Critical (was: Major)
> InputFormatCacheLoaderTest is unstable
>
[
https://issues.apache.org/jira/browse/FLINK-29405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo updated FLINK-29405:
-
Affects Version/s: 1.16.0
> InputFormatCacheLoaderTest is unstable
> ---
[
https://issues.apache.org/jira/browse/FLINK-29405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17609271#comment-17609271
]
Huang Xingbo commented on FLINK-29405:
--
https://dev.azure.com/apache-flink/apache-f
[
https://issues.apache.org/jira/browse/FLINK-29373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee reassigned FLINK-29373:
Assignee: hk__lrzy
> DataStream to table not support BigDecimalTypeInfo
> ---
[
https://issues.apache.org/jira/browse/FLINK-29373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17609270#comment-17609270
]
Jingsong Lee commented on FLINK-29373:
--
[~hk__lrzy] Thanks, assigned to u. CC [~jar
JingsongLi commented on code in PR #298:
URL: https://github.com/apache/flink-table-store/pull/298#discussion_r979506509
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/mergetree/MergeTreeWriter.java:
##
@@ -138,34 +137,45 @@ public void flushMemory() t
[
https://issues.apache.org/jira/browse/FLINK-29406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee updated FLINK-29406:
Component/s: Table SQL / API
> Expose Finish Method For TableFunction
> --
luoyuxia commented on PR #20883:
URL: https://github.com/apache/flink/pull/20883#issuecomment-1257357271
The failure should related to FLINK-29315
--
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
tweise commented on code in PR #385:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/385#discussion_r979497847
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/status/FlinkDeploymentStatus.java:
##
@@ -53,4 +53,7 @@ public class
lincoln lee created FLINK-29406:
---
Summary: Expose Finish Method For TableFunction
Key: FLINK-29406
URL: https://issues.apache.org/jira/browse/FLINK-29406
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-29389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren resolved FLINK-29389.
---
Assignee: Qingsheng Ren
Resolution: Fixed
> Update documentation of JDBC and HBase loo
[
https://issues.apache.org/jira/browse/FLINK-29389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17609265#comment-17609265
]
Qingsheng Ren edited comment on FLINK-29389 at 9/26/22 1:25 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-29389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17609265#comment-17609265
]
Qingsheng Ren commented on FLINK-29389:
---
1.16: 9699ca7ac188d24a3a8d33fc6749b08c10c
PatrickRen merged PR #20892:
URL: https://github.com/apache/flink/pull/20892
--
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
PatrickRen commented on PR #20892:
URL: https://github.com/apache/flink/pull/20892#issuecomment-1257352406
Merging as this is a doc-only PR. Doc validation has passed on CI.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
snuyanzin commented on code in PR #20850:
URL: https://github.com/apache/flink/pull/20850#discussion_r979468073
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/InputFormatCodeGenerator.scala:
##
@@ -80,6 +80,7 @@ object InputFormatCodeGen
[
https://issues.apache.org/jira/browse/FLINK-29365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17609254#comment-17609254
]
Hong Liang Teoh commented on FLINK-29365:
-
Hi [~wilsonwu],
Thanks for reporting
[
https://issues.apache.org/jira/browse/FLINK-29131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17609248#comment-17609248
]
Dylan Meissner edited comment on FLINK-29131 at 9/25/22 8:54 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-29131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17609248#comment-17609248
]
Dylan Meissner commented on FLINK-29131:
The Helm chart changes dramatically to
gyfora commented on code in PR #385:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/385#discussion_r979441596
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/status/FlinkDeploymentStatus.java:
##
@@ -53,4 +53,7 @@ public class
gyfora commented on code in PR #385:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/385#discussion_r979441460
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/status/FlinkDeploymentStatus.java:
##
@@ -53,4 +53,7 @@ public class
[
https://issues.apache.org/jira/browse/FLINK-29109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29109:
---
Labels: pull-request-available (was: )
> Checkpoint path conflict with stateless upgrade mo
tweise opened a new pull request, #385:
URL: https://github.com/apache/flink-kubernetes-operator/pull/385
## What is the purpose of the change
Automatically set jobId for Flink version < 1.16 to avoid conflicts in
checkpoint path (and other jobId based effects).
TODO:
* Unit
flinkbot commented on PR #20897:
URL: https://github.com/apache/flink/pull/20897#issuecomment-1257241665
## CI report:
* 6c41532ee60e7e4c9471b2a2216aeb25fe9aa568 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
saikikun opened a new pull request, #20897:
URL: https://github.com/apache/flink/pull/20897
Fix typo in try-flink/datastream.md
--
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
Chesnay Schepler created FLINK-29405:
Summary: InputFormatCacheLoaderTest is unstable
Key: FLINK-29405
URL: https://issues.apache.org/jira/browse/FLINK-29405
Project: Flink
Issue Type: Te
gyfora commented on PR #384:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/384#issuecomment-1257210648
cc @morhidi
--
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 c
[
https://issues.apache.org/jira/browse/FLINK-29159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29159:
---
Labels: pull-request-available (was: )
> Revisit/harden initial deployment logic
>
gyfora opened a new pull request, #384:
URL: https://github.com/apache/flink-kubernetes-operator/pull/384
## What is the purpose of the change
Fixes a small flaw in the initialDeployment logic that made it useless after
the job was actually submitted. This also simplifies code in othe
gyfora commented on code in PR #383:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/383#discussion_r979406834
##
flink-kubernetes-shaded/pom.xml:
##
@@ -88,6 +103,7 @@ under the License.
META-INF/DEPENDENCIES
[
https://issues.apache.org/jira/browse/FLINK-29315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17609156#comment-17609156
]
Yang Wang commented on FLINK-29315:
---
After more debugging with strace, I found that it
flinkbot commented on PR #20896:
URL: https://github.com/apache/flink/pull/20896#issuecomment-1257183323
## CI report:
* 61ad4277694a7a12e8befb414e8a089d7df85fdb UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
nicai008 opened a new pull request, #20896:
URL: https://github.com/apache/flink/pull/20896
Event Time Temporal Join 的例子中 在关联查询的时候 两个表都有 currency 字段 ，应该将查询中的‘currency
’ 改为orders.currency,
## What is the purpose of the change
*(For example: This pull request makes task
flinkbot commented on PR #20895:
URL: https://github.com/apache/flink/pull/20895#issuecomment-1257155574
## CI report:
* 83d8ee9181512a6466e2eaddf59d113ec26c3cdd UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
zs19940317 opened a new pull request, #20895:
URL: https://github.com/apache/flink/pull/20895
translate a sentence into chinese, maybe this sentence was left when other
people translated it. This sentence is `In production, commonly used sinks
include the StreamingFileSink, various database
70 matches
Mail list logo
