tisonkun commented on PR #56:
URL:
https://github.com/apache/flink-connector-pulsar/pull/56#issuecomment-1655131338
Support keybytes for now to minimize code change. Following work -
1. Add SQL client E2E test
2. Add upsert table factory
3. Revisit key serialization support. I k
[
https://issues.apache.org/jira/browse/FLINK-31168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748254#comment-17748254
]
Matthias Pohl edited comment on FLINK-31168 at 7/28/23 6:46 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-31168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748436#comment-17748436
]
Matthias Pohl commented on FLINK-31168:
---
My suspicion doesn't seem to hold: I coul
[ https://issues.apache.org/jira/browse/FLINK-26541 ]
shizhengchao deleted comment on FLINK-26541:
--
was (Author: tinny):
Why do not use session mode？If application mode supports sql, then I think
there is no different whith session mode.
> SQ
hanyuzheng7 closed pull request #23098: [FLINK-32262] Add MAP_ENTRIES support
URL: https://github.com/apache/flink/pull/23098
--
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.
T
flinkbot commented on PR #23098:
URL: https://github.com/apache/flink/pull/23098#issuecomment-1655074207
## CI report:
* 2a0667be43d20203ef1c1b05119c87c1efbd9030 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32262:
---
Labels: pull-request-available (was: )
> Add MAP_ENTRIES support in SQL & Table API
> -
hanyuzheng7 opened a new pull request, #23098:
URL: https://github.com/apache/flink/pull/23098
Implement the map_entries method to transform a map into an array of
key-value structs in release-1.17.
Description: The current implementation of the map_entries method in the
Flink librar
hanyuzheng7 closed pull request #23097: [FLINK-32564][table] Support Cast From
BYTES to NUMBER
URL: https://github.com/apache/flink/pull/23097
--
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 spe
hanyuzheng7 opened a new pull request, #23097:
URL: https://github.com/apache/flink/pull/23097
### What is the purpose of the change
Implement` CAST` from `BINARY`/`VARBINART`/`BYTES `to `NUMBER`
### Brief change log
` CAST` from `BINARY`/`VARBINART`/`BYTES `to `NUMBER` for Table
FangYongs commented on PR #23087:
URL: https://github.com/apache/flink/pull/23087#issuecomment-1655026823
@libenchao Please help to review this PR when you're free, thanks
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and us
hanyuzheng7 closed pull request #23096: Flink 32262]add map entries support
URL: https://github.com/apache/flink/pull/23096
--
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 u
hanyuzheng7 opened a new pull request, #23096:
URL: https://github.com/apache/flink/pull/23096
## 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 the
[
https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748386#comment-17748386
]
yuanfenghu commented on FLINK-31757:
Is there any progress on this topic? We are als
flinkbot commented on PR #23095:
URL: https://github.com/apache/flink/pull/23095#issuecomment-1654910287
## CI report:
* 56eadbdcc666359c1dafd06382ce16b8a9600983 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32709:
---
Labels: pull-request-available (was: )
> Modify segment size to improve memory utilization
TanYuxin-tyx opened a new pull request, #23095:
URL: https://github.com/apache/flink/pull/23095
## What is the purpose of the change
*Currently, each subpartition in Disk/Remote has a segment size of 8M. When
writing segments to the Disk tier with a parallelism of 1000, on
[
https://issues.apache.org/jira/browse/FLINK-32662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748382#comment-17748382
]
Sergey Nuyanzin commented on FLINK-32662:
-
https://dev.azure.com/apache-flink/ap
[
https://issues.apache.org/jira/browse/FLINK-32681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748380#comment-17748380
]
Sergey Nuyanzin commented on FLINK-32681:
-
https://dev.azure.com/apache-flink/ap
[
https://issues.apache.org/jira/browse/FLINK-32709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuxin Tan reassigned FLINK-32709:
-
Assignee: Yuxin Tan
> Modify segment size to improve memory utilization for Hybrid Shuffle
> --
Yuxin Tan created FLINK-32709:
-
Summary: Modify segment size to improve memory utilization for
Hybrid Shuffle
Key: FLINK-32709
URL: https://issues.apache.org/jira/browse/FLINK-32709
Project: Flink
Wencong Liu created FLINK-32708:
---
Summary: Fix the write logic in remote tier of hybrid shuffle
Key: FLINK-32708
URL: https://issues.apache.org/jira/browse/FLINK-32708
Project: Flink
Issue Type
zhougit86 commented on PR #22624:
URL: https://github.com/apache/flink/pull/22624#issuecomment-1654876318
https://github.com/apache/flink/pull/23028
https://github.com/apache/flink/pull/23029
@snuyanzin Hi master, not sure if this is what you mean create backports?
--
This is an auto
[
https://issues.apache.org/jira/browse/FLINK-32707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
liangjj updated FLINK-32707:
Summary: The timestamp field precision should be set to 0 instead of 1
(was: the timestamp field precisio
liangjj created FLINK-32707:
---
Summary: the timestamp field precision should be set to 0 instead
of 1
Key: FLINK-32707
URL: https://issues.apache.org/jira/browse/FLINK-32707
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-32706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748318#comment-17748318
]
Hanyu Zheng commented on FLINK-32706:
-
[~martijnvisser] can you please assign this t
Hanyu Zheng created FLINK-32706:
---
Summary: Add SPLIT(STRING) support in SQL & Table API
Key: FLINK-32706
URL: https://issues.apache.org/jira/browse/FLINK-32706
Project: Flink
Issue Type: Improv
[
https://issues.apache.org/jira/browse/FLINK-32703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748308#comment-17748308
]
Danny Cranmer commented on FLINK-32703:
---
Merged commit
[{{c8a3979}}|https://githu
[
https://issues.apache.org/jira/browse/FLINK-32693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-32693:
--
Description:
* SocketTextStreamFunction (org.apache.flink.streaming.api.functions.sour
[
https://issues.apache.org/jira/browse/FLINK-32703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer resolved FLINK-32703.
---
Resolution: Fixed
> [hotfix] flink-python POM has a typo for protobuf-java in shading config
[
https://issues.apache.org/jira/browse/FLINK-32703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer reassigned FLINK-32703:
-
Assignee: Hong Liang Teoh
> [hotfix] flink-python POM has a typo for protobuf-java in s
[
https://issues.apache.org/jira/browse/FLINK-32695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-32695:
--
Description:
* ProcessingTimeServiceSource in StreamSourceOperatorLatencyMetricsTest
[
https://issues.apache.org/jira/browse/FLINK-32694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-32694:
--
Description:
* SimpleEndlessSourceWithBloatedState in HeavyDeploymentStressTestProg
[
https://issues.apache.org/jira/browse/FLINK-32695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-32695:
--
Description:
* ProcessingTimeServiceSource in StreamSourceOperatorLatencyMetricsTest
[
https://issues.apache.org/jira/browse/FLINK-32700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748304#comment-17748304
]
Gyula Fora commented on FLINK-32700:
No I don't think we should have a config for th
[
https://issues.apache.org/jira/browse/FLINK-32700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748302#comment-17748302
]
Manan Mangal commented on FLINK-32700:
--
We can create a configuration for this well
[
https://issues.apache.org/jira/browse/FLINK-32690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-32690.
--
Resolution: Fixed
> Report Double.NAN instead of null for missing autoscaler metrics
> ---
[
https://issues.apache.org/jira/browse/FLINK-32690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-32690:
---
Fix Version/s: kubernetes-operator-1.6.0
> Report Double.NAN instead of null for missing autoscaler
[
https://issues.apache.org/jira/browse/FLINK-31168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748254#comment-17748254
]
Matthias Pohl commented on FLINK-31168:
---
The error appears in the
[FileExecutionG
[
https://issues.apache.org/jira/browse/FLINK-31168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reassigned FLINK-31168:
-
Assignee: Matthias Pohl
> JobManagerHAProcessFailureRecoveryITCase failed due to job no
[
https://issues.apache.org/jira/browse/FLINK-32679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748235#comment-17748235
]
Benchao Li commented on FLINK-32679:
{{FilterJoinRule}} is supposed to push filters
1996fanrui commented on PR #23094:
URL: https://github.com/apache/flink/pull/23094#issuecomment-1653883924
Thanks @pnowojski for the quick review.
I added a new commit to remove the `Experimental`, does it make sense?
--
This is an automated message from the Apache Git Service.
To r
[
https://issues.apache.org/jira/browse/FLINK-32548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748194#comment-17748194
]
Piotr Nowojski commented on FLINK-32548:
Good catch, I would bump this to {{Publ
flinkbot commented on PR #23094:
URL: https://github.com/apache/flink/pull/23094#issuecomment-1653775883
## CI report:
* bec215deae3781923d31381dd299b6d775271ce2 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32705:
---
Labels: pull-request-available (was: )
> Remove the beta for watermark alignment
>
flinkbot commented on PR #23093:
URL: https://github.com/apache/flink/pull/23093#issuecomment-1653766187
## CI report:
* db07347cce5f97c6b71495f7db63e8cfc89ca59d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
darren128 opened a new pull request, #23093:
URL: https://github.com/apache/flink/pull/23093
## What is the purpose of the change
Remove suffix `.all` from java opts for application profiling.
## Brief change log
Fix config param for jvm options under application
[
https://issues.apache.org/jira/browse/FLINK-32548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748181#comment-17748181
]
Rui Fan edited comment on FLINK-32548 at 7/27/23 2:35 PM:
--
I se
[
https://issues.apache.org/jira/browse/FLINK-32548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748181#comment-17748181
]
Rui Fan commented on FLINK-32548:
-
I see the WatermarkStrategy#withWatermarkAlignment al
MartijnVisser commented on PR #56:
URL:
https://github.com/apache/flink-connector-pulsar/pull/56#issuecomment-1653739866
> Because we need to take copyright considerations, licenses etc into
account, before that code can be merged into an ASF project.
@tisonkun and I talked about thi
MartijnVisser commented on PR #22930:
URL: https://github.com/apache/flink/pull/22930#issuecomment-1653736165
> What was the purpose of the changes to
[`.idea/vcs.xml`](https://github.com/apache/flink/pull/22930/files#diff-a6dab70bd0e9ffc91d8419ad52225baff3a3e7c9d8e1724f7ed6d96b661d804a)
in
[
https://issues.apache.org/jira/browse/FLINK-32548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748177#comment-17748177
]
Rui Fan commented on FLINK-32548:
-
Thanks for the feedback, I created the FLINK-32705 to
Rui Fan created FLINK-32705:
---
Summary: Remove the beta for watermark alignment
Key: FLINK-32705
URL: https://issues.apache.org/jira/browse/FLINK-32705
Project: Flink
Issue Type: Sub-task
gyfora merged PR #640:
URL: https://github.com/apache/flink-kubernetes-operator/pull/640
--
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
Tartarus0zm commented on code in PR #23060:
URL: https://github.com/apache/flink/pull/23060#discussion_r1276309785
##
docs/content/docs/dev/table/sql/create.md:
##
@@ -557,6 +558,58 @@ INSERT INTO my_ctas_table SELECT id, name, age FROM
source_table WHERE mod(id, 1
{{< top >
[
https://issues.apache.org/jira/browse/FLINK-28013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28013:
---
Labels: pull-request-available (was: )
> java.lang.ClassNotFoundException:
> org.apache.fl
boring-cyborg[bot] commented on PR #17:
URL:
https://github.com/apache/flink-connector-hbase/pull/17#issuecomment-1653614729
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This is a
[
https://issues.apache.org/jira/browse/FLINK-28013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748153#comment-17748153
]
He Wang commented on FLINK-28013:
-
I got the same exception. After comparing the depende
luoyuxia commented on code in PR #23060:
URL: https://github.com/apache/flink/pull/23060#discussion_r1276249794
##
docs/content/docs/dev/table/sql/create.md:
##
@@ -557,6 +558,58 @@ INSERT INTO my_ctas_table SELECT id, name, age FROM
source_table WHERE mod(id, 1
{{< top >}}
gyfora opened a new pull request, #640:
URL: https://github.com/apache/flink-kubernetes-operator/pull/640
(no comment)
--
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 un
gyfora merged PR #639:
URL: https://github.com/apache/flink-kubernetes-operator/pull/639
--
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
luoyuxia commented on code in PR #23046:
URL: https://github.com/apache/flink/pull/23046#discussion_r1276225063
##
docs/content.zh/docs/dev/table/sql/truncate.md:
##
@@ -0,0 +1,163 @@
+---
+title: "TRUNCATE 语句"
+weight: 8
+type: docs
+aliases:
+- /zh/dev/table/sql/truncate.html
jnh5y commented on code in PR #23084:
URL: https://github.com/apache/flink/pull/23084#discussion_r1276239665
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/catalog/UnknownCatalogTest.java:
##
@@ -55,6 +56,52 @@ public class UnknownCatalogTest {
dawidwys commented on PR #23090:
URL: https://github.com/apache/flink/pull/23090#issuecomment-1653538853
But neither `DateTimeUtils` nor `FileSystemTableFactory` use the time zone
setting from `TableConfig`.
* `FileSystemTableFactory` uses:
`SINK_PARTITION_COMMIT_WATERMARK_TIME_ZONE`
KevDi commented on PR #5:
URL:
https://github.com/apache/flink-connector-jdbc/pull/5#issuecomment-1653537091
@MartijnVisser is there any update on this PR? I can also open a new PR with
the fixes from @EchoLee5.
--
This is an automated message from the Apache Git Service.
To respond to
twalthr commented on code in PR #23090:
URL: https://github.com/apache/flink/pull/23090#discussion_r1276199023
##
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/api/TableConfigTest.java:
##
@@ -79,10 +79,8 @@ void testSetAndGetLocalTimeZone() {
@Test
gyfora opened a new pull request, #666:
URL: https://github.com/apache/flink-web/pull/666
(no comment)
--
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-mai
[
https://issues.apache.org/jira/browse/FLINK-32700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748092#comment-17748092
]
Gyula Fora commented on FLINK-32700:
Sounds good, we have to be careful with simply
[
https://issues.apache.org/jira/browse/FLINK-32700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748093#comment-17748093
]
Gyula Fora commented on FLINK-32700:
We should not silently fall back to cancel
> S
[
https://issues.apache.org/jira/browse/FLINK-32700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora reassigned FLINK-32700:
--
Assignee: Manan Mangal
> Support job drain for Savepoint upgrade mode jobs in Flink Operator
flinkbot commented on PR #23092:
URL: https://github.com/apache/flink/pull/23092#issuecomment-1653411824
## CI report:
* e65d9b6c63968ba0ad1604a870b0e63a63aef622 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748089#comment-17748089
]
grandfisher commented on FLINK-32471:
-
HI,[~337361...@qq.com] please review
[PR|htt
patricklucas commented on PR #22987:
URL: https://github.com/apache/flink/pull/22987#issuecomment-1653394915
> @XComp CI looks promising, starting on the backport. Just 1.17 or also
1.16?
Hmm, it seems that there are various other changes that haven't been
backported to release-1.17
Jiang Xin created FLINK-32704:
-
Summary: Supports spilling to disk when feedback channel memory
buffer is full
Key: FLINK-32704
URL: https://issues.apache.org/jira/browse/FLINK-32704
Project: Flink
GrandFisher commented on PR #23088:
URL: https://github.com/apache/flink/pull/23088#issuecomment-1653390224
I don't know how to format xml use flink style , I'm not found in the [flink
IDE dev
doc](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/flinkdev/ide_setup/)
--
Th
dawidwys commented on code in PR #23090:
URL: https://github.com/apache/flink/pull/23090#discussion_r1276104533
##
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/api/TableConfigTest.java:
##
@@ -79,10 +79,8 @@ void testSetAndGetLocalTimeZone() {
@Test
flinkbot commented on PR #23091:
URL: https://github.com/apache/flink/pull/23091#issuecomment-1653387164
## CI report:
* 0ab0625a5a65324415d0ac2d79d685c316a00f7e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
patricklucas commented on PR #22987:
URL: https://github.com/apache/flink/pull/22987#issuecomment-1653380951
@XComp CI looks promising, starting on the backport. Just 1.17 or also 1.16?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
[
https://issues.apache.org/jira/browse/FLINK-32703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32703:
---
Labels: pull-request-available (was: )
> [hotfix] flink-python POM has a typo for protobuf-
hlteoh37 opened a new pull request, #23091:
URL: https://github.com/apache/flink/pull/23091
…f-java in flink-python
## What is the purpose of the change
Fix typo in shading config for `flink-python`. Now it will include
`com.google.protobuf:protobuf-java` in jar.
## Brief ch
Hong Liang Teoh created FLINK-32703:
---
Summary: [hotfix] flink-python POM has a typo for protobuf-java in
shading config
Key: FLINK-32703
URL: https://issues.apache.org/jira/browse/FLINK-32703
Projec
[
https://issues.apache.org/jira/browse/FLINK-28045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-28045:
--
Description:
This ticket should only contain items where SourceFunction is already use
[
https://issues.apache.org/jira/browse/FLINK-28045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747894#comment-17747894
]
Alexander Fedulov commented on FLINK-28045:
---
Hi [~dannycranmer], thanks for th
tisonkun commented on PR #56:
URL:
https://github.com/apache/flink-connector-pulsar/pull/56#issuecomment-1653298964
Update JIRA number, this should cover several subtasks under FLINK-26203.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
twalthr commented on code in PR #23084:
URL: https://github.com/apache/flink/pull/23084#discussion_r1276012516
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/catalog/UnknownCatalogTest.java:
##
@@ -55,6 +56,52 @@ public class UnknownCatalogTest {
flinkbot commented on PR #23090:
URL: https://github.com/apache/flink/pull/23090#issuecomment-1653249486
## CI report:
* 74932acf933e711bbe50f3125227d54a23ce1789 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
twalthr commented on code in PR #23084:
URL: https://github.com/apache/flink/pull/23084#discussion_r1276012516
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/catalog/UnknownCatalogTest.java:
##
@@ -55,6 +56,52 @@ public class UnknownCatalogTest {
[
https://issues.apache.org/jira/browse/FLINK-32689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32689:
---
Labels: pull-request-available (was: )
> Insufficient validation for table.local-time-zone
twalthr opened a new pull request, #23090:
URL: https://github.com/apache/flink/pull/23090
## What is the purpose of the change
This fixes the insufficient validation of ZoneId for setting local time
zones.
## Brief change log
- It ensures that no information is lost whe
[
https://issues.apache.org/jira/browse/FLINK-25438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747875#comment-17747875
]
Sergey Nuyanzin commented on FLINK-25438:
-
similar failure
{noformat}
Jul 25 01:
flinkbot commented on PR #23089:
URL: https://github.com/apache/flink/pull/23089#issuecomment-1653233006
## CI report:
* e8c94e5d9db3ff708e52ac3e952005ec0e5c09e7 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weihua Hu updated FLINK-32702:
--
Description:
There are some streaming examples that depend on flink-connector-datagen, but
didn't pac
[
https://issues.apache.org/jira/browse/FLINK-32662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747874#comment-17747874
]
Sergey Nuyanzin commented on FLINK-32662:
-
https://dev.azure.com/apache-flink/ap
MartijnVisser commented on PR #56:
URL:
https://github.com/apache/flink-connector-pulsar/pull/56#issuecomment-1653220914
> I'll respect all their credits before merging.
@tisonkun This seems to indicate that this contains code that's been
contributed by people outside of the ASF, is
[
https://issues.apache.org/jira/browse/FLINK-32681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-32681:
Labels: test-stability (was: )
> RocksDBStateDownloaderTest.testMultiThreadCleanupOnFailu
[
https://issues.apache.org/jira/browse/FLINK-32702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32702:
---
Labels: pull-request-available (was: )
> streaming examples could not run
> ---
[
https://issues.apache.org/jira/browse/FLINK-32681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747872#comment-17747872
]
Sergey Nuyanzin commented on FLINK-32681:
-
https://dev.azure.com/apache-flink/ap
huwh opened a new pull request, #23089:
URL: https://github.com/apache/flink/pull/23089
## What is the purpose of the change
To resolve a bug that some streaming examples were unable to run. Let the
streaming example jars include flink-connector-datagen.
## Brief change
[
https://issues.apache.org/jira/browse/FLINK-26974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747869#comment-17747869
]
Sergey Nuyanzin commented on FLINK-26974:
-
https://dev.azure.com/apache-flink/ap
[
https://issues.apache.org/jira/browse/FLINK-29977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-29977.
Resolution: Duplicate
> Kafka connector not compatible with kafka-clients 3.3x
> -
1 - 100 of 135 matches
Mail list logo
