[
https://issues.apache.org/jira/browse/FLINK-28786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo closed FLINK-28786.
Resolution: Fixed
Merged into master via e5762a558f3697294cd73da4247a741fc6f73456
Merged into
[
https://issues.apache.org/jira/browse/FLINK-29817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo closed FLINK-29817.
Resolution: Fixed
Merged into master via e5762a558f3697294cd73da4247a741fc6f73456
Merged into
liyubin117 commented on PR #21182:
URL: https://github.com/apache/flink/pull/21182#issuecomment-1319663034
@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
HuangXingBo closed pull request #21342: [FLINK-29817][python] Fix the metadata
in PyFlink requirements
URL: https://github.com/apache/flink/pull/21342
--
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
HuangXingBo closed pull request #21341: [FLINK-28786][python] Fix the NoneType
error on MacOS with M1 Chip
URL: https://github.com/apache/flink/pull/21341
--
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-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17635720#comment-17635720
]
zhanglu153 edited comment on FLINK-30075 at 11/18/22 7:47 AM:
--
1.When is
[
https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17635720#comment-17635720
]
zhanglu153 commented on FLINK-30075:
1.When is the properties object in the Configuration object of
[
https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhanglu153 updated FLINK-30075:
---
Attachment: org.apache.hadoop.conf.Configuration#addDefaultResource.png
> Failed to load data to
[
https://issues.apache.org/jira/browse/FLINK-29639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17635718#comment-17635718
]
Liu commented on FLINK-29639:
-
[~xtsong] Sorry for late reply. I am busy with something recently and thanks
[
https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhanglu153 updated FLINK-30075:
---
Attachment: hadoop2.10.1 org.apache.hadoop.yarn.conf.YarnConfiguration
static code block.png
>
[
https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhanglu153 updated FLINK-30075:
---
Attachment: hadoop2.10.1
[
https://issues.apache.org/jira/browse/FLINK-30042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-30042.
Resolution: Fixed
https://hub.docker.com/layers/chesnay/flink-ci/java_8_11_17_maven_386
[
https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhanglu153 updated FLINK-30075:
---
Attachment: hadoop2.10.1
org.apache.hadoop.mapred.Master#getMasterPrincipal.png
> Failed to load
JingsongLi commented on code in PR #388:
URL: https://github.com/apache/flink-table-store/pull/388#discussion_r1026107900
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/utils/SnapshotManager.java:
##
@@ -90,6 +90,22 @@ public boolean
[
https://issues.apache.org/jira/browse/FLINK-30045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-30045.
Fix Version/s: (was: 1.16.1)
Resolution: Fixed
master:
[
https://issues.apache.org/jira/browse/FLINK-30045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-30045:
-
Issue Type: Technical Debt (was: Bug)
> FromClasspathEntryClassInformationProvider too
zentol merged PR #21335:
URL: https://github.com/apache/flink/pull/21335
--
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:
zjureel commented on code in PR #388:
URL: https://github.com/apache/flink-table-store/pull/388#discussion_r1026103960
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/utils/SnapshotManager.java:
##
@@ -90,6 +90,22 @@ public boolean snapshotExists(long
[
https://issues.apache.org/jira/browse/FLINK-30076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17635705#comment-17635705
]
luoyuxia commented on FLINK-30076:
--
[~kcz] Thanks for reporting.
I try to reproduce your problem, but
Jiabao-Sun commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1026099789
##
flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoKeyExtractor.java:
##
@@ -0,0 +1,139 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhanglu153 updated FLINK-30075:
---
Attachment: Set the properties object in the Configuration object of
DFSClient#namenode proxy in
zentol commented on code in PR #21343:
URL: https://github.com/apache/flink/pull/21343#discussion_r1026094609
##
docs/content.zh/docs/dev/dataset/local_execution.md:
##
@@ -97,7 +97,7 @@ The `LocalEnvironment` allows also to pass custom
configuration values to Flink.
zjureel commented on code in PR #388:
URL: https://github.com/apache/flink-table-store/pull/388#discussion_r1026091394
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/utils/SnapshotManager.java:
##
@@ -90,6 +90,22 @@ public boolean snapshotExists(long
JingsongLi commented on code in PR #388:
URL: https://github.com/apache/flink-table-store/pull/388#discussion_r1026091038
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/utils/SnapshotManager.java:
##
@@ -90,6 +90,22 @@ public boolean
JingsongLi commented on code in PR #388:
URL: https://github.com/apache/flink-table-store/pull/388#discussion_r1026090480
##
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/source/FlinkSourceBuilder.java:
##
@@ -150,20 +153,20 @@ private
[
https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhanglu153 updated FLINK-30075:
---
Attachment: hadoop2.10.1 org.apache.hadoop.security.SaslRpcClient#conf.png
> Failed to load data to
[
https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17635696#comment-17635696
]
zhanglu153 commented on FLINK-30075:
{code:java}
Couldn't set up IO streams:
[
https://issues.apache.org/jira/browse/FLINK-30042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-30042:
-
Summary: Create new CI image with Maven 3.8.6 (was: Create/Use new CI
image with Maven
JingsongLi commented on code in PR #388:
URL: https://github.com/apache/flink-table-store/pull/388#discussion_r1026088012
##
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/source/FlinkSourceBuilder.java:
##
@@ -150,20 +153,20 @@ private
[
https://issues.apache.org/jira/browse/FLINK-29856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17635693#comment-17635693
]
Mason Chen commented on FLINK-29856:
Yes, Savepoint is completed successfully from Flink UI,
zjureel commented on code in PR #388:
URL: https://github.com/apache/flink-table-store/pull/388#discussion_r1026084973
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/utils/SnapshotManager.java:
##
@@ -90,6 +90,22 @@ public boolean snapshotExists(long
[
https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhanglu153 updated FLINK-30075:
---
Attachment:
org.apache.flink.connectors.hive.read.HiveTableInputFormat#createInputSplits.png
>
[
https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhanglu153 updated FLINK-30075:
---
Attachment: hadoop2.8.5 org.apache.hadoop.security.SaslRpcClient#conf.png
> Failed to load data to
[
https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhanglu153 updated FLINK-30075:
---
Attachment: org.apache.hadoop.security.SaslRpcClient.png
> Failed to load data to the cache after
[
https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhanglu153 updated FLINK-30075:
---
Attachment: (was: org.apache.hadoop.security.SallRpcClient.png)
> Failed to load data to the
zoltar9264 commented on PR #21330:
URL: https://github.com/apache/flink/pull/21330#issuecomment-1319614261
@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
tsreaper commented on code in PR #388:
URL: https://github.com/apache/flink-table-store/pull/388#discussion_r1026074919
##
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/source/FlinkSourceBuilder.java:
##
@@ -150,20 +153,20 @@ private
[
https://issues.apache.org/jira/browse/FLINK-30082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30082:
---
Labels: pull-request-available (was: )
> Enable write-buffer-spillable by default only for
JingsongLi opened a new pull request, #389:
URL: https://github.com/apache/flink-table-store/pull/389
After a lot of tests, it is found that the participation of spillable does
not improve HDFS greatly, but will bring some jitters.
In this jira, spillable is enabled only when the object
Jingsong Lee created FLINK-30082:
Summary: Enable write-buffer-spillable by default only for object
storage
Key: FLINK-30082
URL: https://issues.apache.org/jira/browse/FLINK-30082
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-30081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingliang Liu updated FLINK-30081:
--
Description:
In local executor, it's not possible to set different values for
[
https://issues.apache.org/jira/browse/FLINK-30079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingliang Liu updated FLINK-30079:
--
Priority: Minor (was: Major)
> Stop using deprecated TM options in doc
>
[
https://issues.apache.org/jira/browse/FLINK-30081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingliang Liu updated FLINK-30081:
--
Description:
In local executor, it's not possible to set different values for
[
https://issues.apache.org/jira/browse/FLINK-30081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingliang Liu updated FLINK-30081:
--
Description:
In local executor, it's not possible to set different values for
Mingliang Liu created FLINK-30081:
-
Summary: Local executor can not accept different
jvm-overhead.min/max values
Key: FLINK-30081
URL: https://issues.apache.org/jira/browse/FLINK-30081
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-30031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17635681#comment-17635681
]
Jingsong Lee commented on FLINK-30031:
--
I created FLINK-30080 for this.
> flink table store run
Jingsong Lee created FLINK-30080:
Summary: Introduce public programming api and dependency jar for
table store
Key: FLINK-30080
URL: https://issues.apache.org/jira/browse/FLINK-30080
Project: Flink
zhipeng93 merged PR #177:
URL: https://github.com/apache/flink-ml/pull/177
--
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:
zhipeng93 commented on PR #177:
URL: https://github.com/apache/flink-ml/pull/177#issuecomment-1319601221
Thanks for the update. LGTM.
--
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-30031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-30031:
-
Component/s: Table Store
> flink table store run abnormally when shade flink
>
[
https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhanglu153 updated FLINK-30075:
---
Attachment: org.apache.hadoop.security.SallRpcClient.png
> Failed to load data to the cache after
[
https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhanglu153 updated FLINK-30075:
---
Attachment: (was: SaslRpcClient中报错所在的代码.png)
> Failed to load data to the cache after the hive
[
https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhanglu153 updated FLINK-30075:
---
Attachment: SaslRpcClient中报错所在的代码.png
> Failed to load data to the cache after the hive lookup join
[
https://issues.apache.org/jira/browse/FLINK-29987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17635679#comment-17635679
]
Jingsong Lee commented on FLINK-29987:
--
[~Ge] Sounds nice~
>
[
https://issues.apache.org/jira/browse/FLINK-29940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17635678#comment-17635678
]
Mingliang Liu commented on FLINK-29940:
---
Thanks for the comment [~gaoyunhaii] . We have been using
[
https://issues.apache.org/jira/browse/FLINK-30039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17635677#comment-17635677
]
Jingsong Lee commented on FLINK-30039:
--
Hi [~StarBoy1005], if you are using static partition
[
https://issues.apache.org/jira/browse/FLINK-30076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-30076:
Component/s: Connectors / Hive
> hive join mysql error
> -
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-30028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-30028.
Fix Version/s: table-store-0.3.0
Assignee: Hang HOU
Resolution: Fixed
master:
JingsongLi commented on PR #381:
URL:
https://github.com/apache/flink-table-store/pull/381#issuecomment-1319595654
>
Thanks!
--
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
flinkbot commented on PR #21343:
URL: https://github.com/apache/flink/pull/21343#issuecomment-1319592218
## CI report:
* f3b6580ba775e175cd691e529ad264a5268a60a5 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-30079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingliang Liu updated FLINK-30079:
--
Issue Type: Bug (was: Improvement)
> Stop using deprecated TM options in doc
>
[
https://issues.apache.org/jira/browse/FLINK-30079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingliang Liu updated FLINK-30079:
--
Affects Version/s: 1.16.0
> Stop using deprecated TM options in doc
>
[
https://issues.apache.org/jira/browse/FLINK-30076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zck updated FLINK-30076:
Description:
There is no problem when reading hive table parquet alone, but after doing join
with MySQL table,
[
https://issues.apache.org/jira/browse/FLINK-30079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30079:
---
Labels: pull-request-available (was: )
> Stop using deprecated TM options in doc
>
[
https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhanglu153 updated FLINK-30075:
---
Description:
When I test kafka and hive lookup join, only the connection between tm and
zookeeper
liuml07 opened a new pull request, #21343:
URL: https://github.com/apache/flink/pull/21343
## What is the purpose of the change
The option ConfigConstants.TASK_MANAGER_MEMORY_FRACTION_KEY was deprecated
and configuring it should have no effect now. However, in the
Mingliang Liu created FLINK-30079:
-
Summary: Stop using deprecated TM options in doc
Key: FLINK-30079
URL: https://issues.apache.org/jira/browse/FLINK-30079
Project: Flink
Issue Type:
JingsongLi commented on code in PR #351:
URL: https://github.com/apache/flink-table-store/pull/351#discussion_r1026054061
##
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/source/FileStoreSource.java:
##
@@ -100,6 +100,9 @@ public
JingsongLi commented on code in PR #351:
URL: https://github.com/apache/flink-table-store/pull/351#discussion_r1026053108
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/utils/SnapshotManager.java:
##
@@ -90,6 +90,27 @@ public boolean
JingsongLi commented on code in PR #351:
URL: https://github.com/apache/flink-table-store/pull/351#discussion_r1026052672
##
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/source/FileStoreSource.java:
##
@@ -100,6 +100,9 @@ public
dianfu commented on code in PR #21342:
URL: https://github.com/apache/flink/pull/21342#discussion_r1026051644
##
docs/content/release-notes/flink-1.16.md:
##
@@ -209,7 +209,7 @@ For support of Python3.9 and M1, PyFlink updates a series
dependencies version:
```
JingsongLi commented on code in PR #347:
URL: https://github.com/apache/flink-table-store/pull/347#discussion_r1026049498
##
flink-table-store-spark/src/test/java/org/apache/flink/table/store/spark/SparkReadITCase.java:
##
@@ -281,6 +281,176 @@ public void testAddColumn()
[
https://issues.apache.org/jira/browse/FLINK-27847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee reassigned FLINK-27847:
Assignee: Shammon
> SchemaManager supports schema evolution
>
yunfengzhou-hub commented on code in PR #177:
URL: https://github.com/apache/flink-ml/pull/177#discussion_r1026042607
##
flink-ml-core/src/test/java/org/apache/flink/ml/common/datastream/DataStreamUtilsTest.java:
##
@@ -86,6 +87,29 @@ public void testAggregate() throws
zhipeng93 commented on code in PR #177:
URL: https://github.com/apache/flink-ml/pull/177#discussion_r1025970532
##
flink-ml-core/src/test/java/org/apache/flink/ml/common/datastream/DataStreamUtilsTest.java:
##
@@ -86,6 +87,29 @@ public void testAggregate() throws Exception {
[
https://issues.apache.org/jira/browse/FLINK-30033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-30033.
Fix Version/s: table-store-0.3.0
Assignee: Shammon
Resolution: Fixed
master:
JingsongLi merged PR #383:
URL: https://github.com/apache/flink-table-store/pull/383
--
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-27843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-27843.
Assignee: Shammon
Resolution: Fixed
master: 157966f696522f3c7e939c4cd3713b01c9081017
>
JingsongLi merged PR #376:
URL: https://github.com/apache/flink-table-store/pull/376
--
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-29232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29232:
---
Labels: pull-request-available (was: )
> File store continuous reading support
JingsongLi opened a new pull request, #388:
URL: https://github.com/apache/flink-table-store/pull/388
The file store can find a suitable snapshot according to start timestamp and
read incremental data from it.
--
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhanglu153 updated FLINK-30075:
---
Description:
When I test kafka and hive lookup join, only the connection between tm and
zookeeper
[
https://issues.apache.org/jira/browse/FLINK-29232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee reassigned FLINK-29232:
Assignee: Jingsong Lee
> File store continuous reading support from_timestamp scan mode
[
https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17635635#comment-17635635
]
zhanglu153 commented on FLINK-30075:
After the ChildFirstClassLoader is created, the default will be
Xuannan Su created FLINK-30078:
--
Summary: Temporal join should finish when the left table is
bounded and finished
Key: FLINK-30078
URL: https://issues.apache.org/jira/browse/FLINK-30078
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-30048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17635629#comment-17635629
]
Lijie Wang commented on FLINK-30048:
Thanks for [~masteryhx] 's detailed explanation. If so, +1 for
hanjie created FLINK-30077:
--
Summary: k8s jobmanager pod repeated restart
Key: FLINK-30077
URL: https://issues.apache.org/jira/browse/FLINK-30077
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-29929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yubin Li closed FLINK-29929.
Resolution: Won't Fix
> Correct conversions from ResolvedSchema to TableSchema
>
liyubin117 closed pull request #21260: [FLINK-29929][table] Correct conversions
from ResolvedSchema to TableSchema
URL: https://github.com/apache/flink/pull/21260
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
zck created FLINK-30076:
---
Summary: hive join mysql error
Key: FLINK-30076
URL: https://issues.apache.org/jira/browse/FLINK-30076
Project: Flink
Issue Type: Bug
Components: Table SQL /
zhanglu153 created FLINK-30075:
--
Summary: Failed to load data to the cache after the hive lookup
join task is restarted
Key: FLINK-30075
URL: https://issues.apache.org/jira/browse/FLINK-30075
Project:
[
https://issues.apache.org/jira/browse/FLINK-29639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song closed FLINK-29639.
Fix Version/s: 1.17.0
Resolution: Done
master (1.17):
xintongsong closed pull request #21331: [FLINK-29639] Print resourceId of
remote taskmanager when encounter transport exception.
URL: https://github.com/apache/flink/pull/21331
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
JingsongLi merged PR #387:
URL: https://github.com/apache/flink-table-store/pull/387
--
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-30073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17635599#comment-17635599
]
Xintong Song commented on FLINK-30073:
--
I'm no more familiar with the background of FLINK-14484
yunfengzhou-hub commented on code in PR #174:
URL: https://github.com/apache/flink-ml/pull/174#discussion_r1025077674
##
flink-ml-lib/src/main/java/org/apache/flink/ml/feature/countvectorizer/CountVectorizerModel.java:
##
@@ -0,0 +1,188 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-28672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
songwenbin updated FLINK-28672:
---
Description:
# 配置了'properties.allow.auto.create.topics' =
'false'，但job执行后都会创建出mocktest27的topic
[
https://issues.apache.org/jira/browse/FLINK-28672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
songwenbin updated FLINK-28672:
---
Summary: properties.allow.auto.create.topics disable (was:
properties.allow.auto.create.topics无效)
JLLeitschuh opened a new pull request, #387:
URL: https://github.com/apache/flink-table-store/pull/387
# Security Vulnerability Fix
This pull request fixes a Zip Slip vulnerability either due to an
insufficient, or missing guard when unzipping zip files.
Even if you deem,
Jiabao-Sun commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1025581498
##
flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter/PartitionStrategy.java:
##
@@ -0,0 +1,65 @@
+/*
+
1 - 100 of 269 matches
Mail list logo
