Xin Hao created FLINK-28385:
---
Summary: Change the validator to return an error if the Jar URI is
an empty string
Key: FLINK-28385
URL: https://issues.apache.org/jira/browse/FLINK-28385
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-27620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-27620:
---
Assignee: luoyuxia
> Support percent_rank
>
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-27620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-27620:
Component/s: Table SQL / API
> Support percent_rank
>
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-27620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-27620:
Fix Version/s: 1.16.0
> Support percent_rank
>
>
> Key: FLINK-27620
[
https://issues.apache.org/jira/browse/FLINK-27619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-27619:
---
Assignee: luoyuxia
> Support NTILE
> -
>
> Key: FLINK-27619
>
[
https://issues.apache.org/jira/browse/FLINK-27619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-27619:
Component/s: Table SQL / API
> Support NTILE
> -
>
> Key: FLINK-27619
>
[
https://issues.apache.org/jira/browse/FLINK-27619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-27619:
Fix Version/s: 1.16.0
> Support NTILE
> -
>
> Key: FLINK-27619
>
[
https://issues.apache.org/jira/browse/FLINK-27618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-27618:
Fix Version/s: 1.16.0
> Support CumeDist
>
>
> Key: FLINK-27618
>
[
https://issues.apache.org/jira/browse/FLINK-27618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-27618:
Component/s: Table SQL / API
> Suuport CumeDist
>
>
> Key: FLINK-27618
>
[
https://issues.apache.org/jira/browse/FLINK-27618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-27618:
Summary: Support CumeDist (was: Suuport CumeDist)
> Support CumeDist
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-27618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-27618:
---
Assignee: luoyuxia
> Suuport CumeDist
>
>
> Key: FLINK-27618
>
haoxins opened a new pull request, #292:
URL: https://github.com/apache/flink-kubernetes-operator/pull/292
This error may happen if I use Golang to submit the job with some bugs.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
zoltar9264 commented on PR #20148:
URL: https://github.com/apache/flink/pull/20148#issuecomment-1174631201
Thanks a lot @Myasuka , @1996fanrui .
--
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
lsyldliu commented on code in PR #20001:
URL: https://github.com/apache/flink/pull/20001#discussion_r913373639
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/batch/sql/FunctionITCase.java:
##
@@ -0,0 +1,167 @@
+/*
+ * Licensed to the
luoyuxia commented on PR #19218:
URL: https://github.com/apache/flink/pull/19218#issuecomment-1174587038
@fsk119 Thanks for review. Now, I add function `current_database` for flink
itselft. So that both Flink sql and Hive dialect can use it.
--
This is an automated message from the
JingsongLi commented on PR #195:
URL:
https://github.com/apache/flink-table-store/pull/195#issuecomment-1174583780
Thanks @SteNicholas for the contribution, we can finish some configuration
refactor first.
--
This is an automated message from the Apache Git Service.
To respond to the
JingsongLi commented on code in PR #195:
URL: https://github.com/apache/flink-table-store/pull/195#discussion_r913367319
##
docs/content/docs/deployment/configuration.md:
##
@@ -0,0 +1,49 @@
+---
+title: "Configuration"
+weight: 1
+type: docs
+aliases:
+-
JingsongLi commented on code in PR #196:
URL: https://github.com/apache/flink-table-store/pull/196#discussion_r913362008
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/TableStoreOptions.java:
##
@@ -0,0 +1,583 @@
+/*
+ * Licensed to the Apache Software
link3280 commented on PR #20159:
URL: https://github.com/apache/flink/pull/20159#issuecomment-1174575436
cc @wuchong @fsk119 @godfreyhe
--
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
[
https://issues.apache.org/jira/browse/FLINK-28118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-28118:
-
Priority: Major (was: Minor)
> Introduce TableStoreOptions to merge all options
>
[
https://issues.apache.org/jira/browse/FLINK-26901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee reassigned FLINK-26901:
Assignee: Nicholas Jiang
> Introduce config options document for table store
>
[
https://issues.apache.org/jira/browse/FLINK-26901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-26901:
-
Priority: Major (was: Minor)
> Introduce config options document for table store
>
[
https://issues.apache.org/jira/browse/FLINK-28198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17562352#comment-17562352
]
Huang Xingbo commented on FLINK-28198:
--
JingsongLi commented on PR #196:
URL:
https://github.com/apache/flink-table-store/pull/196#issuecomment-1174572554
Thanks @hililiwei for your contribution. left two comments.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
JingsongLi commented on code in PR #196:
URL: https://github.com/apache/flink-table-store/pull/196#discussion_r913362290
##
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/AbstractTableStoreFactory.java:
##
@@ -139,7 +138,13 @@ static
curcur commented on PR #20091:
URL: https://github.com/apache/flink/pull/20091#issuecomment-1174569765
> Got it, thanks. My concern is that probably we should fix the error
handling in `CheckpointFailureManager`, instead of `mkdirs` call:
>
> ```
> case
syhily commented on PR #19099:
URL: https://github.com/apache/flink/pull/19099#issuecomment-1174564916
Some commits in #19473 will be moved to this PR. I'll add them as soon as
the block PR has been merged into the flink repository.
--
This is an automated message from the Apache Git
flinkbot commented on PR #20159:
URL: https://github.com/apache/flink/pull/20159#issuecomment-1174564013
## CI report:
* fba1490c2c59d4c3b817b6e1420d3caac7fe0492 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
HuangXingBo commented on code in PR #19140:
URL: https://github.com/apache/flink/pull/19140#discussion_r913355932
##
flink-python/src/main/java/org/apache/flink/table/utils/python/PythonTableUtils.java:
##
@@ -89,8 +89,8 @@ public final class PythonTableUtils {
private
lincoln-lil commented on PR #20118:
URL: https://github.com/apache/flink/pull/20118#issuecomment-1174561623
@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-26270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17562347#comment-17562347
]
fengjk commented on FLINK-26270:
hi [~martijnvisser] , I submitted a PR but so far no results , Can you
[
https://issues.apache.org/jira/browse/FLINK-26270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17562348#comment-17562348
]
fengjk commented on FLINK-26270:
hi [~martijnvisser] , I submitted a PR but so far no results , Can you
[ https://issues.apache.org/jira/browse/FLINK-26270 ]
fengjk deleted comment on FLINK-26270:
was (Author: JIRAUSER284851):
hi [~martijnvisser] , I submitted a PR but so far no results , Can you take a
look ? thanks
> Flink SQL write data to kafka
[
https://issues.apache.org/jira/browse/FLINK-27009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17562346#comment-17562346
]
Yang Wang commented on FLINK-27009:
---
AFAIK, they are trying to work on the sql-client so that it could
[
https://issues.apache.org/jira/browse/FLINK-28360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28360:
---
Labels: pull-request-available (was: )
> Support stop job statement in SQL client
>
link3280 opened a new pull request, #20159:
URL: https://github.com/apache/flink/pull/20159
## What is the purpose of the change
Support stop job statement in SQL client. Subtask of FLIP-222.
## Brief change log
- Support stop-job statement in Flink SQL parser
-
LadyForest commented on code in PR #191:
URL: https://github.com/apache/flink-table-store/pull/191#discussion_r913354250
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/FileStoreOptions.java:
##
@@ -155,6 +156,14 @@ public class FileStoreOptions
[
https://issues.apache.org/jira/browse/FLINK-28250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17562344#comment-17562344
]
Qingsheng Ren commented on FLINK-28250:
---
Thanks for the detailed investigation [~jinshuangxian] !
fsk119 commented on code in PR #19846:
URL: https://github.com/apache/flink/pull/19846#discussion_r913352482
##
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/result/ResultStore.java:
##
@@ -37,6 +37,13 @@ public class ResultStore {
fsk119 commented on code in PR #19846:
URL: https://github.com/apache/flink/pull/19846#discussion_r913351720
##
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/operation/OperationExecutor.java:
##
@@ -0,0 +1,172 @@
+/*
+ * Licensed to the
fsk119 commented on code in PR #19846:
URL: https://github.com/apache/flink/pull/19846#discussion_r913350238
##
flink-table/flink-sql-gateway/src/test/resources/sql/insert.q:
##
@@ -0,0 +1,182 @@
+# insert.q - insert
Review Comment:
Currently only `ADD JAR/REMOVE
[
https://issues.apache.org/jira/browse/FLINK-28381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28381:
---
Labels: pull-request-available (was: )
> Add Spark Reader documentation
>
LadyForest commented on code in PR #194:
URL: https://github.com/apache/flink-table-store/pull/194#discussion_r913349205
##
docs/content/docs/engines/spark.md:
##
@@ -0,0 +1,80 @@
+---
+title: "Spark"
+weight: 3
+type: docs
+aliases:
+- /engines/spark.html
+---
+
+
+# Spark
+
[
https://issues.apache.org/jira/browse/FLINK-28349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17562335#comment-17562335
]
Yang Wang commented on FLINK-28349:
---
The upstream project Flink has supported to generate a static job
[
https://issues.apache.org/jira/browse/FLINK-28118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28118:
---
Labels: pull-request-available (was: )
> Introduce TableStoreOptions to merge all options
hililiwei opened a new pull request, #196:
URL: https://github.com/apache/flink-table-store/pull/196
Currently we have OPTIONS in various places, which is harder to maintain, we
could have just one class that contains all the OPTIONS, including
MergeTreeOptions
FileStoreOptions
fsk119 commented on code in PR #19846:
URL: https://github.com/apache/flink/pull/19846#discussion_r913345494
##
flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/service/SqlGatewayServiceStatementITCase.java:
##
@@ -0,0 +1,294 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-28274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17562313#comment-17562313
]
Lijie Wang commented on FLINK-28274:
I have one more question, does it also occur with other
[
https://issues.apache.org/jira/browse/FLINK-28274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17562311#comment-17562311
]
Lijie Wang commented on FLINK-28274:
I think it only occur for {{ContinuousFileMonitoringFunction
LadyForest commented on code in PR #193:
URL: https://github.com/apache/flink-table-store/pull/193#discussion_r913340834
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/schema/TableSchema.java:
##
@@ -129,6 +134,33 @@ public Map options() {
LadyForest commented on code in PR #193:
URL: https://github.com/apache/flink-table-store/pull/193#discussion_r913340759
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/FileStoreOptions.java:
##
@@ -155,6 +155,14 @@ public class FileStoreOptions
[
https://issues.apache.org/jira/browse/FLINK-27854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren resolved FLINK-27854.
---
Fix Version/s: 1.16.0
Resolution: Fixed
> Refactor FlinkImageBuilder and
[
https://issues.apache.org/jira/browse/FLINK-27854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17562310#comment-17562310
]
Qingsheng Ren commented on FLINK-27854:
---
Merged in master 45ad242beb7a6d87df239a9069728c1594c905c4
JingsongLi merged PR #190:
URL: https://github.com/apache/flink-table-store/pull/190
--
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:
LadyForest commented on code in PR #193:
URL: https://github.com/apache/flink-table-store/pull/193#discussion_r913339588
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/FileStoreOptions.java:
##
@@ -155,6 +155,14 @@ public class FileStoreOptions
LadyForest commented on code in PR #193:
URL: https://github.com/apache/flink-table-store/pull/193#discussion_r913339347
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/FileStoreOptions.java:
##
@@ -155,6 +155,14 @@ public class FileStoreOptions
Kwafoor closed pull request #18498: [FLINK-25801][ metrics]add cpu processor
metric of taskmanager
URL: https://github.com/apache/flink/pull/18498
--
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
PatrickRen merged PR #19856:
URL: https://github.com/apache/flink/pull/19856
--
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:
fsk119 commented on code in PR #19846:
URL: https://github.com/apache/flink/pull/19846#discussion_r913338177
##
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/operation/OperationExecutor.java:
##
@@ -0,0 +1,172 @@
+/*
+ * Licensed to the
JingsongLi commented on code in PR #182:
URL: https://github.com/apache/flink-table-store/pull/182#discussion_r913336130
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/operation/AbstractFileStoreScan.java:
##
@@ -272,4 +272,15 @@ private boolean
fsk119 commented on code in PR #19846:
URL: https://github.com/apache/flink/pull/19846#discussion_r913336031
##
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/operation/OperationExecutor.java:
##
@@ -0,0 +1,172 @@
+/*
+ * Licensed to the
zoltar9264 commented on PR #20152:
URL: https://github.com/apache/flink/pull/20152#issuecomment-1174527623
@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
zoltar9264 commented on PR #20093:
URL: https://github.com/apache/flink/pull/20093#issuecomment-1174525564
@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-26372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17562307#comment-17562307
]
Feifan Wang commented on FLINK-26372:
-
Hi [~roman] , I checked the code and not find no-op
[
https://issues.apache.org/jira/browse/FLINK-28267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17562308#comment-17562308
]
lincoln lee commented on FLINK-28267:
-
It seems to appear frequently:
[
https://issues.apache.org/jira/browse/FLINK-23995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-23995:
-
Parent: FLINK-26360
Issue Type: Sub-task (was: Bug)
> Hive dialect: `insert overwrite table
Jingsong Lee created FLINK-28384:
Summary: Add CatalogLock support for HiveCatalog in table store
Key: FLINK-28384
URL: https://issues.apache.org/jira/browse/FLINK-28384
Project: Flink
Issue
HuangXingBo commented on code in PR #20156:
URL: https://github.com/apache/flink/pull/20156#discussion_r913328921
##
flink-python/dev/lint-python.sh:
##
@@ -854,3 +863,8 @@ pushd "$FLINK_PYTHON_DIR" &> /dev/null
if [ $skip_checks -eq 0 ]; then
check_stage
fi
+
+if [[
SteNicholas opened a new pull request, #195:
URL: https://github.com/apache/flink-table-store/pull/195
Flink Table Store provides the configuration of LogStore and FileStore,
which config options can be documented. It's necessary to introduce config
options document for table store.
HuangXingBo commented on code in PR #20156:
URL: https://github.com/apache/flink/pull/20156#discussion_r913327366
##
flink-python/dev/lint-python.sh:
##
@@ -854,3 +863,8 @@ pushd "$FLINK_PYTHON_DIR" &> /dev/null
if [ $skip_checks -eq 0 ]; then
check_stage
fi
+
+if [[
[
https://issues.apache.org/jira/browse/FLINK-27570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Underwood updated FLINK-27570:
--
Summary: Checkpoint path error does not cause the job to stop (was: A
checkpoint path error does not
fsk119 commented on PR #20149:
URL: https://github.com/apache/flink/pull/20149#issuecomment-1174511108
@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.
JesseAtSZ commented on PR #20091:
URL: https://github.com/apache/flink/pull/20091#issuecomment-1174498642
@rkhachatryan This is also my question when reading the code. I'm curious
about why this exception was ignored. I don't know the original intention of
ignoring this exception before
[
https://issues.apache.org/jira/browse/FLINK-28369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-28369:
Affects Version/s: (was: 1.15.0)
> Support PARSE_URL bulit-in function in Table API
>
[
https://issues.apache.org/jira/browse/FLINK-28354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-28354.
---
Resolution: Fixed
Merged to master via 5a13c939bc26f38d98f76592b69db81a13de083e
> Support instr and locate
[
https://issues.apache.org/jira/browse/FLINK-28354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-28354:
Affects Version/s: (was: 1.15.0)
> Support instr and locate bulit-in function in Table API
>
dianfu merged PR #20132:
URL: https://github.com/apache/flink/pull/20132
--
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:
rkhachatryan commented on PR #20091:
URL: https://github.com/apache/flink/pull/20091#issuecomment-1174397933
Got it, thanks. My concern is that probably we should fix the error handling
in `CheckpointFailureManager`, instead of `mkdirs` call:
```
case FINALIZE_CHECKPOINT_FAILURE:
[
https://issues.apache.org/jira/browse/FLINK-28365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lim Qing Wei resolved FLINK-28365.
--
Resolution: Not A Problem
> TO_TIMESTAMP lose precision beyond seconds
>
[
https://issues.apache.org/jira/browse/FLINK-28365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17562284#comment-17562284
]
Lim Qing Wei commented on FLINK-28365:
--
Hi, I am not able to reproduce this easily with a small
[
https://issues.apache.org/jira/browse/FLINK-28357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17562234#comment-17562234
]
Piotr Nowojski edited comment on FLINK-28357 at 7/4/22 7:38 PM:
Thanks
syhily commented on code in PR #19972:
URL: https://github.com/apache/flink/pull/19972#discussion_r913230836
##
flink-python/pyflink/datastream/connectors/pulsar.py:
##
@@ -138,10 +138,10 @@ def latest() -> 'StartCursor':
return StartCursor(JStartCursor.latest())
syhily commented on PR #19473:
URL: https://github.com/apache/flink/pull/19473#issuecomment-1174078355
@PatrickRen I have splitted this PR into multiple commits.
--
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-23528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-23528:
--
Fix Version/s: 1.15.2
(was: 1.15.1)
> stop-with-savepoint can fail
MartijnVisser commented on code in PR #20156:
URL: https://github.com/apache/flink/pull/20156#discussion_r913153914
##
flink-python/dev/lint-python.sh:
##
@@ -854,3 +863,8 @@ pushd "$FLINK_PYTHON_DIR" &> /dev/null
if [ $skip_checks -eq 0 ]; then
check_stage
fi
+
+if [[
flinkbot commented on PR #20158:
URL: https://github.com/apache/flink/pull/20158#issuecomment-1173995987
## CI report:
* 0a2c1e75426bd88efab0bbe8662005b86f9eb22d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-28357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17562234#comment-17562234
]
Piotr Nowojski commented on FLINK-28357:
Thanks for the bug report. Indeed there was a bug where
[
https://issues.apache.org/jira/browse/FLINK-28357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28357:
---
Labels: pull-request-available (was: )
> Watermark issue when recovering Finished sources
pnowojski opened a new pull request, #20158:
URL: https://github.com/apache/flink/pull/20158
Otherwise tasks can not correctly determine number of inputs. This was
causing an
issue where restored as finished OneInputStreamTask was waiting for
MAX_WATERMARK
from two inputs, where the
qingwei91 closed pull request #20136: FLINK-16024 [jdbc-connector] JDBC Filter
Pushdown
URL: https://github.com/apache/flink/pull/20136
--
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
qingwei91 closed pull request #20138: FLINK-16024 [jdbc-connector] JDBC Filter
Pushdown
URL: https://github.com/apache/flink/pull/20138
--
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
qingwei91 commented on PR #20138:
URL: https://github.com/apache/flink/pull/20138#issuecomment-1173977923
@MartijnVisser oh, I see, I guess patch is only reserved for vulnerabilities
or bug fixing?
That's unfortunate, I will just contribute to master for 1.16 then, thanks
for
[
https://issues.apache.org/jira/browse/FLINK-28357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-28357:
--
Assignee: Piotr Nowojski
> Watermark issue when recovering Finished sources
>
[
https://issues.apache.org/jira/browse/FLINK-28366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1756#comment-1756
]
Jeya Prakash Thanigaivel commented on FLINK-28366:
--
Thanks [~martijnvisser]
> Support
flinkbot commented on PR #20157:
URL: https://github.com/apache/flink/pull/20157#issuecomment-1173919858
## CI report:
* c3e0f700b95236c15eaa2bf5703b08a105396d00 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
dzikosc commented on code in PR #20133:
URL: https://github.com/apache/flink/pull/20133#discussion_r913080950
##
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java:
##
@@ -149,7 +149,9 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-28326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28326:
---
Labels: pull-request-available test-stability (was: test-stability)
>
reswqa opened a new pull request, #20157:
URL: https://github.com/apache/flink/pull/20157
## What is the purpose of the change
fix unstable test ResultPartitionTest.testIdleAndBackPressuredTime: Due to
the race condition, the main thread may recycle buffer before the request
thread
rmetzger commented on PR #20117:
URL: https://github.com/apache/flink/pull/20117#issuecomment-1173910688
Thanks a lot by opening this PR.
Have you looked into adding an integration test for this issue? It would be
nice to have a test for this, to make sure nobody or nothing breaks this
1 - 100 of 296 matches
Mail list logo
