hehuiyuan closed pull request #20644: [FLINK-29052][TABLE]Support TO_TIMESTAMP
built-in function in Table API
URL: https://github.com/apache/flink/pull/20644
--
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 t
[
https://issues.apache.org/jira/browse/FLINK-29437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29437:
---
Labels: pull-request-available (was: )
> The partition of data before and after the Kafka S
Zakelly commented on PR #20942:
URL: https://github.com/apache/flink/pull/20942#issuecomment-1272465222
@curcur @pnowojski Would you please take 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
[
https://issues.apache.org/jira/browse/FLINK-29308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-29308.
---
Resolution: Won't Fix
> NoResourceAvailableException fails the batch job
> -
zjureel commented on code in PR #305:
URL: https://github.com/apache/flink-table-store/pull/305#discussion_r990738706
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/operation/FileStoreWrite.java:
##
@@ -52,4 +56,35 @@ RecordWriter createEmptyWriter(
flinkbot commented on PR #20993:
URL: https://github.com/apache/flink/pull/20993#issuecomment-1272453771
## CI report:
* f256b422f7d92ad53e5481ca9f920e534913b005 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29552:
---
Labels: pull-request-available (was: )
> Fix documentation usage examples for DAYOFYEAR, DA
cun8cun8 opened a new pull request, #20993:
URL: https://github.com/apache/flink/pull/20993
…OFMONTH, and DAYOFFEEK functions
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC.
zhipeng93 commented on code in PR #161:
URL: https://github.com/apache/flink-ml/pull/161#discussion_r990731155
##
docs/content/docs/operators/stats/chisqtest.md:
##
@@ -0,0 +1,187 @@
+---
+title: "ChiSqTest"
+type: docs
+aliases:
+- /operators/stats/chisqtest.html
+---
+
+
+
+##
weibozhao commented on code in PR #156:
URL: https://github.com/apache/flink-ml/pull/156#discussion_r990730701
##
docs/content/docs/operators/feature/vectorassembler.md:
##
@@ -27,8 +27,10 @@ under the License.
Review Comment:
After discussing offline, we need not add this
weibozhao commented on code in PR #156:
URL: https://github.com/apache/flink-ml/pull/156#discussion_r990730701
##
docs/content/docs/operators/feature/vectorassembler.md:
##
@@ -27,8 +27,10 @@ under the License.
Review Comment:
Discuss offline, we need not add this paramete
weibozhao commented on code in PR #156:
URL: https://github.com/apache/flink-ml/pull/156#discussion_r990730701
##
docs/content/docs/operators/feature/vectorassembler.md:
##
@@ -27,8 +27,10 @@ under the License.
Review Comment:
Discuss with some people, we need not add this
[
https://issues.apache.org/jira/browse/FLINK-29552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangjingcun updated FLINK-29552:
-
Summary: Fix documentation usage examples for DAYOFYEAR, DAYOFMONTH, and
DAYOFFEEK functions (w
[
https://issues.apache.org/jira/browse/FLINK-29552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17614571#comment-17614571
]
zhangjingcun commented on FLINK-29552:
--
Hi [~dianfu] I'm interested in this ticket
[
https://issues.apache.org/jira/browse/FLINK-29552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangjingcun updated FLINK-29552:
-
Attachment: image-2022-10-09-11-21-56-033.png
> Repair the instructions for DAYOFYEAR, DAYOFMONT
[
https://issues.apache.org/jira/browse/FLINK-29552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangjingcun updated FLINK-29552:
-
Description: !image-2022-10-09-11-21-56-033.png!
> Repair the instructions for DAYOFYEAR, DAYOFM
zhangjingcun created FLINK-29552:
Summary: Repair the instructions for DAYOFYEAR, DAYOFMONTH, and
DAYOFFEEK functions
Key: FLINK-29552
URL: https://issues.apache.org/jira/browse/FLINK-29552
Project: F
lindong28 merged PR #158:
URL: https://github.com/apache/flink-ml/pull/158
--
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.apac
flinkbot commented on PR #20992:
URL: https://github.com/apache/flink/pull/20992#issuecomment-1272438712
## CI report:
* c808a0dbabab0d097cbb766fa7150aa47339c482 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29483:
---
Labels: pull-request-available (was: )
> flink python udf arrow in thread model bug
> -
liuyongvs opened a new pull request, #20992:
URL: https://github.com/apache/flink/pull/20992
## What is the purpose of the change
*vectorized python scalar function should fallback to process mode*
## Does this pull request potentially affect one of the following parts:
[
https://issues.apache.org/jira/browse/FLINK-29551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu updated FLINK-29551:
--
Description: Currently, regarding adaptive hash join, when falling back to
sort-merge join, it sorts a
dalongliu created FLINK-29551:
-
Summary: Improving adaptive hash join by using sort merge join
strategy per partition instead of all partitions
Key: FLINK-29551
URL: https://issues.apache.org/jira/browse/FLINK-29551
[
https://issues.apache.org/jira/browse/FLINK-29520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangjingcun closed FLINK-29520.
Fix Version/s: 1.16.0
Resolution: Duplicate
> Support PARSE_URL built-in function in Table
[
https://issues.apache.org/jira/browse/FLINK-29525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangjingcun closed FLINK-29525.
Fix Version/s: 1.16.0
Resolution: Duplicate
> Support INSTR、LEFT、RIGHT built-in function in
[
https://issues.apache.org/jira/browse/FLINK-29521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangjingcun closed FLINK-29521.
Fix Version/s: 1.16.0
Resolution: Duplicate
> Support REVERSE built-in function in Table AP
[
https://issues.apache.org/jira/browse/FLINK-29523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangjingcun closed FLINK-29523.
Fix Version/s: 1.16.0
Resolution: Duplicate
> Support STR_TO_MAP、SUBSTR built-in function i
[
https://issues.apache.org/jira/browse/FLINK-29522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangjingcun closed FLINK-29522.
Fix Version/s: 1.16.0
Resolution: Duplicate
> Support SPLIT_INDEX built-in function in Tabl
weibozhao commented on code in PR #156:
URL: https://github.com/apache/flink-ml/pull/156#discussion_r990719982
##
flink-ml-lib/src/main/java/org/apache/flink/ml/feature/vectorassembler/VectorAssembler.java:
##
@@ -47,7 +47,9 @@
/**
* A Transformer which combines a given lis
[
https://issues.apache.org/jira/browse/FLINK-29524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangjingcun resolved FLINK-29524.
--
Fix Version/s: 1.16.0
Resolution: Duplicate
> Support DECODE、ENCODE built-in function i
[
https://issues.apache.org/jira/browse/FLINK-29483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17614560#comment-17614560
]
jackylau commented on FLINK-29483:
--
yes [~hxbks2ks]
> flink python udf arrow in threa
weibozhao commented on code in PR #156:
URL: https://github.com/apache/flink-ml/pull/156#discussion_r990719982
##
flink-ml-lib/src/main/java/org/apache/flink/ml/feature/vectorassembler/VectorAssembler.java:
##
@@ -47,7 +47,9 @@
/**
* A Transformer which combines a given lis
weibozhao commented on code in PR #156:
URL: https://github.com/apache/flink-ml/pull/156#discussion_r990719844
##
flink-ml-lib/src/main/java/org/apache/flink/ml/feature/vectorassembler/VectorAssemblerParams.java:
##
@@ -21,11 +21,31 @@
import org.apache.flink.ml.common.param.Ha
[
https://issues.apache.org/jira/browse/FLINK-27054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17614551#comment-17614551
]
Nick Levandoski commented on FLINK-27054:
-
Im running into the same issues with
[
https://issues.apache.org/jira/browse/FLINK-25538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17614534#comment-17614534
]
Ashmeet Kandhari commented on FLINK-25538:
--
Hi [~mapohl]
I have raised a PR w
flinkbot commented on PR #20991:
URL: https://github.com/apache/flink/pull/20991#issuecomment-1272375576
## CI report:
* ff2e4a8ff3a6444267e2a2c9f03a4e3a057e9619 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-25538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-25538:
---
Labels: pull-request-available starter (was: starter)
> [JUnit5 Migration] Module: flink-co
ashmeet-kandhari opened a new pull request, #20991:
URL: https://github.com/apache/flink/pull/20991
## What is the purpose of the change
*This pull request migrates the flink-connector-kafka module unit test cases
to Junit 5*
## Brief change log
- *Updated simple junit
[
https://issues.apache.org/jira/browse/FLINK-29550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17614527#comment-17614527
]
roa commented on FLINK-29550:
-
when I change volume to ebs and added below, It looks work.
{
[
https://issues.apache.org/jira/browse/FLINK-29550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17614517#comment-17614517
]
roa commented on FLINK-29550:
-
and below is logged configurations (sorted)
{code:java}
blob.
roa created FLINK-29550:
---
Summary: example "basic-checkpoint-ha.yaml" not working
Key: FLINK-29550
URL: https://issues.apache.org/jira/browse/FLINK-29550
Project: Flink
Issue Type: Bug
Compon
[
https://issues.apache.org/jira/browse/FLINK-29549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Samrat Deb updated FLINK-29549:
---
Description:
Currently , Flink sql hive connector support hive metastore as hardcoded
metastore-uri
[
https://issues.apache.org/jira/browse/FLINK-29549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Samrat Deb updated FLINK-29549:
---
Description:
Currently , Flink sql hive connector support hive metastore as hardcoded
metastore-uri
Samrat Deb created FLINK-29549:
--
Summary: Flink sql to add support of using AWS glue as metastore
Key: FLINK-29549
URL: https://issues.apache.org/jira/browse/FLINK-29549
Project: Flink
Issue Typ
hlteoh37 commented on code in PR #574:
URL: https://github.com/apache/flink-web/pull/574#discussion_r990657848
##
_posts/2022-10-10-1.16-announcement.md:
##
@@ -0,0 +1,401 @@
+---
+layout: post
+title: "Announcing the Release of Apache Flink 1.16"
+subtitle: ""
+date: 2022-10-1
flinkbot commented on PR #20990:
URL: https://github.com/apache/flink/pull/20990#issuecomment-1272340429
## CI report:
* dd660a27dd7fd351a28d57c0a8b08901c6bbb6dc UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29050:
---
Labels: pull-request-available starter (was: starter)
> [JUnit5 Migration] Module: flink-ha
RocMarshal opened a new pull request, #20990:
URL: https://github.com/apache/flink/pull/20990
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way we avoid re-transferring them
[
https://issues.apache.org/jira/browse/FLINK-28569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17614484#comment-17614484
]
lincoln lee commented on FLINK-28569:
-
[~godfreyhe] I think it's valueable to port t
flinkbot commented on PR #20989:
URL: https://github.com/apache/flink/pull/20989#issuecomment-1272308115
## CI report:
* edd539a63fe3b04cc995d44e8524d011632817ed UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29548:
---
Labels: pull-request-available (was: )
> Remove deprecated class files of the 'flink-test-u
RocMarshal opened a new pull request, #20989:
URL: https://github.com/apache/flink/pull/20989
## What is the purpose of the change
Remove deprecated class files of the 'flink-test-utils' module.
## Brief change log
*Only code-cleanup change.*
De
[
https://issues.apache.org/jira/browse/FLINK-29548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal updated FLINK-29548:
---
Fix Version/s: 1.17.0
(was: 1.16.1)
> Remove deprecated class files of the 'f
RocMarshal created FLINK-29548:
--
Summary: Remove deprecated class files of the 'flink-test-utils'
module.
Key: FLINK-29548
URL: https://issues.apache.org/jira/browse/FLINK-29548
Project: Flink
flinkbot commented on PR #20988:
URL: https://github.com/apache/flink/pull/20988#issuecomment-1272302953
## CI report:
* 23ab26a1a3e51733fbf2b7ccf11a73db756bfd38 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29547:
---
Labels: pull-request-available (was: )
> Select a[1] which is array type for parquet compl
lsyldliu commented on PR #20988:
URL: https://github.com/apache/flink/pull/20988#issuecomment-1272302236
cc @wuchong
--
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 uns
lsyldliu opened a new pull request, #20988:
URL: https://github.com/apache/flink/pull/20988
## What is the purpose of the change
Fix the bug of Select a[1] which is array type for parquet complex type
throw ClassCastException
## Brief change log
- *Fix the bug of Sele
dalongliu created FLINK-29547:
-
Summary: Select a[1] which is array type for parquet complex type
throw ClassCastException
Key: FLINK-29547
URL: https://issues.apache.org/jira/browse/FLINK-29547
Project:
Hui Wang created FLINK-29546:
Summary: UDF：Failed to compile split code, falling back to
original code
Key: FLINK-29546
URL: https://issues.apache.org/jira/browse/FLINK-29546
Project: Flink
Issu
flinkbot commented on PR #20987:
URL: https://github.com/apache/flink/pull/20987#issuecomment-1272292752
## CI report:
* 52e0dcbe18c41d13a8fa90376715f1a54128fcc3 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Samrat002 opened a new pull request, #20987:
URL: https://github.com/apache/flink/pull/20987
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way we avoid re-transferring them
Samrat002 commented on PR #20908:
URL: https://github.com/apache/flink/pull/20908#issuecomment-1272291494
@y0908105023 did you get any chance to look at the failure ?
it would be great if you can
thank you
--
This is an automated message from the Apache Git Service.
To respond
[
https://issues.apache.org/jira/browse/FLINK-29491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-29491.
Resolution: Invalid
> Primary key without partition field can be supported from full changelog
> -
[
https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaogang zhou updated FLINK-29545:
--
Description:
the task dag is like attached file. when the task is started to consume from
ear
[
https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaogang zhou updated FLINK-29545:
--
Description:
the task dag is like attached file. when the task is started to consume from
ear
[
https://issues.apache.org/jira/browse/FLINK-29293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29293:
---
Labels: pull-request-available (was: )
> Introduce a MergeFunction for full compaction
> --
tsreaper opened a new pull request, #310:
URL: https://github.com/apache/flink-table-store/pull/310
This is the first step to introduce a special `MergeFunction` for full
compaction. We need to know the level of each `KeyValue` so we can determine
which `KeyValue` is the result of the last
[
https://issues.apache.org/jira/browse/FLINK-29517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-29517.
---
Fix Version/s: 1.17.0
Resolution: Fixed
Merged to master via d1cb177c91b41a5387814ad60d1799c08caf3ad9
[
https://issues.apache.org/jira/browse/FLINK-29517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-29517:
Summary: Update documentation about DATE_FORMAT to state that it's
supported in Table API (was: Support D
dianfu merged PR #20985:
URL: https://github.com/apache/flink/pull/20985
--
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.apache
HeChuanXUPT closed pull request #18310: [FLINK-16627] Flink-SQL json format
add non-null optinon
URL: https://github.com/apache/flink/pull/18310
--
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
Shenjiaqi commented on code in PR #20860:
URL: https://github.com/apache/flink/pull/20860#discussion_r990617300
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/memory/ByteStreamStateHandle.java:
##
@@ -148,7 +148,7 @@ public int read(byte[] b, int off, int len) thr
Shenjiaqi commented on code in PR #20860:
URL: https://github.com/apache/flink/pull/20860#discussion_r990613086
##
flink-runtime/src/test/java/org/apache/flink/runtime/state/memory/ByteStreamStateHandleTest.java:
##
@@ -172,4 +172,15 @@ public void testBulkReadINdexOutOfBounds()
Shenjiaqi commented on code in PR #20860:
URL: https://github.com/apache/flink/pull/20860#discussion_r990613601
##
flink-runtime/src/test/java/org/apache/flink/runtime/state/memory/ByteStreamStateHandleTest.java:
##
@@ -172,4 +172,15 @@ public void testBulkReadINdexOutOfBounds()
Shenjiaqi commented on code in PR #20860:
URL: https://github.com/apache/flink/pull/20860#discussion_r990613581
##
flink-runtime/src/test/java/org/apache/flink/runtime/state/memory/ByteStreamStateHandleTest.java:
##
@@ -172,4 +172,15 @@ public void testBulkReadINdexOutOfBounds()
[
https://issues.apache.org/jira/browse/FLINK-29292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-29292.
Resolution: Fixed
master: e4c19b66a8af319dd9f412aed250683d54969b34
> Change MergeFunction to prod
JingsongLi merged PR #308:
URL: https://github.com/apache/flink-table-store/pull/308
--
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...@
LadyForest commented on PR #20652:
URL: https://github.com/apache/flink/pull/20652#issuecomment-1272273196
@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
Shenjiaqi commented on code in PR #20860:
URL: https://github.com/apache/flink/pull/20860#discussion_r990613581
##
flink-runtime/src/test/java/org/apache/flink/runtime/state/memory/ByteStreamStateHandleTest.java:
##
@@ -172,4 +172,15 @@ public void testBulkReadINdexOutOfBounds()
[
https://issues.apache.org/jira/browse/FLINK-29352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-29352.
---
Fix Version/s: 1.17.0
Resolution: Fixed
Merged to master via 8d5e27740c34dac4685ba8539c2bec7303314ae6
dianfu closed pull request #20974: [FLINK-29352]Support CONVERT_TZ built-in
function in Table API
URL: https://github.com/apache/flink/pull/20974
--
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-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17614415#comment-17614415
]
xiaogang zhou edited comment on FLINK-29545 at 10/8/22 8:26 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17614415#comment-17614415
]
xiaogang zhou edited comment on FLINK-29545 at 10/8/22 8:24 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17614415#comment-17614415
]
xiaogang zhou commented on FLINK-29545:
---
i can help collect if further evidence ne
[
https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaogang zhou updated FLINK-29545:
--
Description:
the task dag is like attached file. when the task is started to consume from
ear
JingsongLi merged PR #20981:
URL: https://github.com/apache/flink/pull/20981
--
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
Shenjiaqi commented on code in PR #20860:
URL: https://github.com/apache/flink/pull/20860#discussion_r990609029
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/memory/ByteStreamStateHandle.java:
##
@@ -148,7 +148,7 @@ public int read(byte[] b, int off, int len) thr
[
https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaogang zhou updated FLINK-29545:
--
Attachment: task acknowledge na.png
> kafka consuming stop when trigger first checkpoint
> ---
JingsongLi merged PR #20939:
URL: https://github.com/apache/flink/pull/20939
--
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
[
https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaogang zhou updated FLINK-29545:
--
Attachment: backpressure 100 busy 0.png
> kafka consuming stop when trigger first checkpoint
>
[
https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaogang zhou updated FLINK-29545:
--
Description:
the task dag is like attached file. when the task is started to consume from
ear
JingsongLi merged PR #20938:
URL: https://github.com/apache/flink/pull/20938
--
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
[
https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaogang zhou updated FLINK-29545:
--
Attachment: task dag.png
> kafka consuming stop when trigger first checkpoint
> --
xiaogang zhou created FLINK-29545:
-
Summary: kafka consuming stop when trigger first checkpoint
Key: FLINK-29545
URL: https://issues.apache.org/jira/browse/FLINK-29545
Project: Flink
Issue Ty
JingsongLi commented on code in PR #308:
URL: https://github.com/apache/flink-table-store/pull/308#discussion_r990607817
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/mergetree/compact/PartialUpdateMergeFunction.java:
##
@@ -63,12 +67,19 @@ public voi
leletan commented on PR #20852:
URL: https://github.com/apache/flink/pull/20852#issuecomment-1272258337
@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 #20986:
URL: https://github.com/apache/flink/pull/20986#issuecomment-1272257327
## CI report:
* b82ed4da19c5d1aace1879147ddaf7a0f244ec6d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee reopened FLINK-29345:
--
> Too many open files in table store orc writer
> -
>
[
https://issues.apache.org/jira/browse/FLINK-29345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-29345.
Fix Version/s: (was: table-store-0.2.1)
Resolution: Fixed
Re-merged in:
master: bee050f
1 - 100 of 115 matches
Mail list logo
