Jiabao-Sun commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1010626817
##
flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/config/MongoReadOptions.java:
##
@@ -0,0 +1,224 @@
+/*
+ * Licensed to
Jiabao-Sun commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1010737083
##
flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/MongoSink.java:
##
@@ -0,0 +1,82 @@
+/*
+ * Licensed to the Apache
Jiabao-Sun commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1010743536
##
flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/config/MongoReadOptions.java:
##
@@ -0,0 +1,224 @@
+/*
+ * Licensed to
Jiabao-Sun commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1010733740
##
flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils/MongoConstants.java:
##
@@ -0,0 +1,69 @@
+/*
+ * Licensed to the
Jiabao-Sun commented on PR #1:
URL:
https://github.com/apache/flink-connector-mongodb/pull/1#issuecomment-1298937872
Thanks @zentol for the detailed review.
I have made some changes to your comments.
Other changes will be done today.
--
This is an automated message from the Apache
ericxiao251 commented on PR #21077:
URL: https://github.com/apache/flink/pull/21077#issuecomment-1298937784
> 2. For AsyncRetryPredicate, we might have a uniform wrapper for Java
version of AsyncRetryPredicate. Then we do not need to have Scala version of
FixedDelayRetryStrategy and
Jiabao-Sun commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1010734402
##
flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils/MongoSerdeUtils.java:
##
@@ -0,0 +1,90 @@
+/*
+ * Licensed to
Jiabao-Sun commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1010744798
##
flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/MongoSourceBuilder.java:
##
@@ -0,0 +1,219 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-29814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai closed FLINK-29814.
---
Resolution: Fixed
Merged to flink-statefun/master:
Jiabao-Sun commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1010756431
##
flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer/serializer/MongoSerializationSchema.java:
##
@@ -0,0 +1,65 @@
+/*
tzulitai closed pull request #319: [FLINK-29814][statefun] Change supported
Flink version to 1.15.2
URL: https://github.com/apache/flink-statefun/pull/319
--
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
tzulitai commented on PR #319:
URL: https://github.com/apache/flink-statefun/pull/319#issuecomment-1298826258
Merged to `master`: b4a85ef031e539e7c2580a796246e2896d533d8f
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
syhily commented on PR #21204:
URL: https://github.com/apache/flink/pull/21204#issuecomment-1299101588
`KafkaShuffleExactlyOnceITCase` breaks all my PRs. I don't know how to
bypass it.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
tzulitai commented on PR #319:
URL: https://github.com/apache/flink-statefun/pull/319#issuecomment-1298804771
Thanks @galenwarren for the PR and @FilKarnicki for testing this as well.
+1 to merge, merging ...
--
This is an automated message from the Apache Git Service.
To respond
dependabot[bot] opened a new pull request, #322:
URL: https://github.com/apache/flink-statefun/pull/322
Bumps [protobuf-java](https://github.com/protocolbuffers/protobuf) from
3.7.1 to 3.16.3.
Release notes
Sourced from
dependabot[bot] opened a new pull request, #320:
URL: https://github.com/apache/flink-statefun/pull/320
Bumps [jackson-databind](https://github.com/FasterXML/jackson) from 2.13.2.2
to 2.13.4.1.
Commits
See full diff in https://github.com/FasterXML/jackson/commits;>compare view
dependabot[bot] opened a new pull request, #321:
URL: https://github.com/apache/flink-statefun/pull/321
Bumps [junit](https://github.com/junit-team/junit4) from 4.12 to 4.13.1.
Release notes
Sourced from https://github.com/junit-team/junit4/releases;>junit's
releases.
JUnit
qingwei91 commented on PR #20140:
URL: https://github.com/apache/flink/pull/20140#issuecomment-1298952830
Hi @libenchao , this is the new commit I added to address your comment.
I also added support IS NULL and IS NOT NULL as these 2 are quite common
--
This is an automated message
Jiabao-Sun commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1010740286
##
flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer/MongoWriter.java:
##
@@ -0,0 +1,183 @@
+/*
+ * Licensed to the
Jiabao-Sun commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1010751226
##
flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer/serializer/MongoSerializationSchema.java:
##
@@ -0,0 +1,65 @@
+/*
tisonkun commented on PR #21204:
URL: https://github.com/apache/flink/pull/21204#issuecomment-1299400454
@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.
[
https://issues.apache.org/jira/browse/FLINK-29839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chenqizhu updated FLINK-29839:
--
Description:
I had starting the SQL Gateway with the HiveServer2 Endpoint, and then I
submit SQL
[
https://issues.apache.org/jira/browse/FLINK-29816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627442#comment-17627442
]
Weijie Guo commented on FLINK-29816:
[~xieyi] Yes,This phenomenon is normal. When restoring, the
flinkbot commented on PR #21218:
URL: https://github.com/apache/flink/pull/21218#issuecomment-1299556409
## CI report:
* 9449f25fd6e8f9db3f2d013d20f5132b90dcfa9d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627466#comment-17627466
]
James Busche commented on FLINK-29536:
--
[~tagarr] [~tedhtchang]
Helm: I believe it works as
fredia commented on code in PR #21050:
URL: https://github.com/apache/flink/pull/21050#discussion_r1011089971
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistryImpl.java:
##
@@ -95,60 +95,78 @@ public StreamStateHandle registerReference(
chenqizhu created FLINK-29839:
-
Summary: SQL Gateway with hiveserver2 throw exception
Key: FLINK-29839
URL: https://issues.apache.org/jira/browse/FLINK-29839
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-29816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627428#comment-17627428
]
Xie Yi edited comment on FLINK-29816 at 11/2/22 3:10 AM:
-
I also found some
[
https://issues.apache.org/jira/browse/FLINK-29816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627420#comment-17627420
]
Xie Yi edited comment on FLINK-29816 at 11/2/22 3:11 AM:
-
[~Weijie Guo] I
[
https://issues.apache.org/jira/browse/FLINK-29839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chenqizhu updated FLINK-29839:
--
Priority: Critical (was: Major)
> HiveServer2 endpoint doesn't support TGetInfoType value
tsreaper closed pull request #343: [FLINK-29805] Fix incorrect snapshot filter
when snapshots are committing too slow
URL: https://github.com/apache/flink-table-store/pull/343
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
Caizhi Weng created FLINK-29842:
---
Summary: Change commitIdentifier in Table Store snapshot to long
value
Key: FLINK-29842
URL: https://issues.apache.org/jira/browse/FLINK-29842
Project: Flink
libenchao commented on code in PR #20140:
URL: https://github.com/apache/flink/pull/20140#discussion_r101371
##
flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcFilterPushdownPreparedStatementVisitor.java:
##
@@ -93,39 +99,74 @@
[
https://issues.apache.org/jira/browse/FLINK-29841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627448#comment-17627448
]
hcj commented on FLINK-29841:
-
[~leonard] "these values are" is more appropriate?
>
[
https://issues.apache.org/jira/browse/FLINK-29816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627450#comment-17627450
]
Weijie Guo commented on FLINK-29816:
# Because the restored channel can work normally in this stage,
Hangxiang Yu created FLINK-29844:
Summary: FLIP-263: Improve resolving schema compatibility
Key: FLINK-29844
URL: https://issues.apache.org/jira/browse/FLINK-29844
Project: Flink
Issue Type:
Eric Xiao created FLINK-29837:
-
Summary: SQL API does not expose the RowKind of the Row for
processing Changelogs
Key: FLINK-29837
URL: https://issues.apache.org/jira/browse/FLINK-29837
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-29816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627428#comment-17627428
]
Xie Yi edited comment on FLINK-29816 at 11/2/22 2:57 AM:
-
I also found some
[ https://issues.apache.org/jira/browse/FLINK-29816 ]
Xie Yi deleted comment on FLINK-29816:
was (Author: xieyi):
I have some confusions
1. Why registerTimer during restoreGate?
2. Why Userfunction in ProcessWindowFunction is desinged to be
Jiabao-Sun commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1011146094
##
flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/config/MongoWriteOptions.java:
##
@@ -0,0 +1,205 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-29843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29843:
---
Labels: pull-request-available (was: )
> Euclidean Distance Measure generates NAN distance
luoyuxia created FLINK-29838:
Summary: Hive streaming sink for partitioned table should contain
metastore by default
Key: FLINK-29838
URL: https://issues.apache.org/jira/browse/FLINK-29838
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-29816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627428#comment-17627428
]
Xie Yi commented on FLINK-29816:
I also found some phenomenon
h4. h4. 1. userfunction in
[
https://issues.apache.org/jira/browse/FLINK-29837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627431#comment-17627431
]
luoyuxia commented on FLINK-29837:
--
> it was a bit misleading to see that the `{{{}op{}}}` column
Caizhi Weng created FLINK-29840:
---
Summary: Old record may overwrite new record in Table Store when
snapshot committing is slow
Key: FLINK-29840
URL: https://issues.apache.org/jira/browse/FLINK-29840
[
https://issues.apache.org/jira/browse/FLINK-29816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627428#comment-17627428
]
Xie Yi edited comment on FLINK-29816 at 11/2/22 3:11 AM:
-
I also found some
[
https://issues.apache.org/jira/browse/FLINK-29839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chenqizhu updated FLINK-29839:
--
Description:
I had starting the SQL Gateway with the HiveServer2 Endpoint, and then I
submit SQL
[
https://issues.apache.org/jira/browse/FLINK-29536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627467#comment-17627467
]
James Busche commented on FLINK-29536:
--
When I build an OLM bundle of the PR and deploy it on
flinkbot commented on PR #21217:
URL: https://github.com/apache/flink/pull/21217#issuecomment-1299480931
## CI report:
* 2e38a6e48cfd26dff9bbee85cdb1c58b79fda248 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
czy006 commented on code in PR #21012:
URL: https://github.com/apache/flink/pull/21012#discussion_r1011107976
##
flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/handlers/JarHandlerParameterTest.java:
##
@@ -69,6 +71,11 @@ enum ProgramArgsParType {
[
https://issues.apache.org/jira/browse/FLINK-29841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627446#comment-17627446
]
Leonard Xu commented on FLINK-29841:
[~hcj] I checked our docs website, the display is ok. What
Yunfeng Zhou created FLINK-29843:
Summary: Euclidean Distance Measure generates NAN distance values
Key: FLINK-29843
URL: https://issues.apache.org/jira/browse/FLINK-29843
Project: Flink
klion26 commented on code in PR #21050:
URL: https://github.com/apache/flink/pull/21050#discussion_r1011061072
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistryImpl.java:
##
@@ -95,60 +95,78 @@ public StreamStateHandle registerReference(
[
https://issues.apache.org/jira/browse/FLINK-29817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627413#comment-17627413
]
Huang Xingbo commented on FLINK-29817:
--
I think we can optimize the `metadata` to solve this
[
https://issues.apache.org/jira/browse/FLINK-29817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo updated FLINK-29817:
-
Fix Version/s: 1.17.0
1.16.1
> Published metadata for apache-flink in pypi
[
https://issues.apache.org/jira/browse/FLINK-29817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo reassigned FLINK-29817:
Assignee: Huang Xingbo
> Published metadata for apache-flink in pypi are inconsistent
[
https://issues.apache.org/jira/browse/FLINK-29565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29565:
---
Labels: pull-request-available (was: )
> In Flink per job mode, the logs printed by
[
https://issues.apache.org/jira/browse/FLINK-29844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hangxiang Yu updated FLINK-29844:
-
Description:
Details can be seen in
[
https://issues.apache.org/jira/browse/FLINK-29461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo reassigned FLINK-29461:
Assignee: Huang Xingbo
> ProcessDataStreamStreamingTests.test_process_function unstable
[
https://issues.apache.org/jira/browse/FLINK-29816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627420#comment-17627420
]
Xie Yi commented on FLINK-29816:
I didn't use unalignCheckpoint, I had test flink 1.14.0, 1.15.2,
wangshiwei13363 opened a new pull request, #21217:
URL: https://github.com/apache/flink/pull/21217
## What is the purpose of the change
In Flink per job mode, the logs printed by taskManager on the web UI will
not be highlighted, because the log contents are annotated due to
[
https://issues.apache.org/jira/browse/FLINK-29816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xie Yi updated FLINK-29816:
---
Attachment: image-2022-11-02-10-42-21-099.png
> Userfunction exception in ProcessWindowFunction was called
[
https://issues.apache.org/jira/browse/FLINK-29839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chenqizhu updated FLINK-29839:
--
Description:
I had starting the SQL Gateway with the HiveServer2 Endpoint, and then I
submit SQL
[
https://issues.apache.org/jira/browse/FLINK-29839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chenqizhu updated FLINK-29839:
--
Description:
I had starting the SQL Gateway with the HiveServer2 Endpoint, and then I
submit SQL
[
https://issues.apache.org/jira/browse/FLINK-29816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627443#comment-17627443
]
Xie Yi commented on FLINK-29816:
I have some confusions
1. Why registerTimer during restoreGate?
2.
[
https://issues.apache.org/jira/browse/FLINK-29839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chenqizhu updated FLINK-29839:
--
Summary: HiveServer2 endpoint doesn't support TGetInfoType value
'CLI_ODBC_KEYWORDS' (was: SQL
hcj created FLINK-29841:
---
Summary: docs/content/docs/deployment/config.md has error
Key: FLINK-29841
URL: https://issues.apache.org/jira/browse/FLINK-29841
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-29839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chenqizhu updated FLINK-29839:
--
Component/s: Connectors / Hive
> HiveServer2 endpoint doesn't support TGetInfoType value
[
https://issues.apache.org/jira/browse/FLINK-29839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627444#comment-17627444
]
Leonard Xu commented on FLINK-29839:
CC [~fsk119] Could you take a look this issue？
> HiveServer2
[
https://issues.apache.org/jira/browse/FLINK-29831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627456#comment-17627456
]
luoyuxia commented on FLINK-29831:
--
The HiveTableSourceStatisticsReportTest /
[
https://issues.apache.org/jira/browse/FLINK-29831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627456#comment-17627456
]
luoyuxia edited comment on FLINK-29831 at 11/2/22 4:13 AM:
---
The
Jiabao-Sun commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1011195989
##
flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/MongoSourceEnumerator.java:
##
@@ -0,0 +1,127 @@
+/*
+ *
XComp commented on PR #21137:
URL: https://github.com/apache/flink/pull/21137#issuecomment-1299313832
Thanks for your patience on that PR. I gave it another thought: You're right
about the issue with the 5ms delay being necessary to enter the synchronized
block of the `grantLeadership`
[
https://issues.apache.org/jira/browse/FLINK-29831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29831:
---
Labels: pull-request-available test-stability (was: test-stability)
> Multiple Hive tests
luoyuxia opened a new pull request, #21218:
URL: https://github.com/apache/flink/pull/21218
## What is the purpose of the change
Fix the test fest failure for hive3
## Brief change log
- update the expected build-in function number as hive3.1.3 add a new
function
[
https://issues.apache.org/jira/browse/FLINK-29711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17626950#comment-17626950
]
Durgesh Mishra edited comment on FLINK-29711 at 11/2/22 4:51 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-29711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17626950#comment-17626950
]
Durgesh Mishra edited comment on FLINK-29711 at 11/2/22 4:52 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-29823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29823:
---
Labels: pull-request-available (was: )
> Support get schema for table snapshot
>
flinkbot commented on PR #21209:
URL: https://github.com/apache/flink/pull/21209#issuecomment-1298070041
## CI report:
* 028d3672b553885c08b327f3638241101b03 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29818:
---
Labels: pull-request-available (was: )
> HsResultPartitionTest.testAvailability fails
>
reswqa opened a new pull request, #21209:
URL: https://github.com/apache/flink/pull/21209
## What is the purpose of the change
*Fix the unstable test HsResultPartitionTest.testAvailability*
## Brief change log
- *Fix an incorrect test case in NetworkBufferTest*
zjureel commented on PR #344:
URL:
https://github.com/apache/flink-table-store/pull/344#issuecomment-1298083836
@JingsongLi What do you think of this feature, and can you help to review
it? THX
--
This is an automated message from the Apache Git Service.
To respond to the message,
[
https://issues.apache.org/jira/browse/FLINK-29826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17626996#comment-17626996
]
Martijn Visser commented on FLINK-29826:
This most likely won't be fixed, since most likely
[
https://issues.apache.org/jira/browse/FLINK-29829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yubin Li updated FLINK-29829:
-
Description:
Delete last line separator during explain results generation in design, but in
fact, just
[
https://issues.apache.org/jira/browse/FLINK-20578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-20578:
--
Assignee: Eric Xiao
> Cannot create empty array using ARRAY[]
>
[
https://issues.apache.org/jira/browse/FLINK-29755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627004#comment-17627004
]
Martijn Visser commented on FLINK-29755:
I'm assuming that
Martijn Visser created FLINK-29830:
--
Summary:
PulsarSinkITCase$DeliveryGuaranteeTest.writeRecordsToPulsar failed
Key: FLINK-29830
URL: https://issues.apache.org/jira/browse/FLINK-29830
Project:
[
https://issues.apache.org/jira/browse/FLINK-29461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-29461:
---
Priority: Critical (was: Major)
> ProcessDataStreamStreamingTests.test_process_function
[
https://issues.apache.org/jira/browse/FLINK-29461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627008#comment-17627008
]
Martijn Visser commented on FLINK-29461:
liyubin117 opened a new pull request, #21211:
URL: https://github.com/apache/flink/pull/21211
## What is the purpose of the change
align explain results in different platforms.
## Brief change log
* use jdk line separator instead of last charactor
## Does this
[
https://issues.apache.org/jira/browse/FLINK-29829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29829:
---
Labels: pull-request-available (was: )
> align explain results in different platforms
>
[
https://issues.apache.org/jira/browse/FLINK-29830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627020#comment-17627020
]
Matthias Pohl commented on FLINK-29830:
---
zjureel opened a new pull request, #345:
URL: https://github.com/apache/flink-table-store/pull/345
The `default` is a keyword in SQL and can't be the default database name in
table store, the default name will be renamed to `default_database` in this PR.
--
This is an automated message
[
https://issues.apache.org/jira/browse/FLINK-29832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29832:
---
Labels: pull-request-available (was: )
> Refactor default database name in flink table
[
https://issues.apache.org/jira/browse/FLINK-29427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627022#comment-17627022
]
Weijie Guo commented on FLINK-29427:
Another instance:
[
https://issues.apache.org/jira/browse/FLINK-29653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29653:
---
Labels: pull-request-available (was: )
> close DynamicResult but it was already closed
>
CallMeSurprise opened a new pull request, #21212:
URL: https://github.com/apache/flink/pull/21212
## What is the purpose of the change
This pull request constructs result in ResultStore in format of [sessionId,
[resultId, result]].
## Brief change log
-
[
https://issues.apache.org/jira/browse/FLINK-27916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627036#comment-17627036
]
Martijn Visser commented on FLINK-27916:
zentol merged PR #21198:
URL: https://github.com/apache/flink/pull/21198
--
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:
[
https://issues.apache.org/jira/browse/FLINK-6099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-6099:
--
Labels: auto-deprioritized-minor starter (was: auto-deprioritized-minor
newbie)
> not able to auto
1 - 100 of 239 matches
Mail list logo
