[
https://issues.apache.org/jira/browse/FLINK-29477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang reassigned FLINK-29477:
Assignee: Juntao Hu
> ClassCastException when collect primitive array to Python
>
[
https://issues.apache.org/jira/browse/FLINK-29477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang closed FLINK-29477.
Fix Version/s: 1.16.0
(was: 1.17.0)
(was: 1.16.1)
HuangXingBo closed pull request #21016: [FLINK-29477][python] Fix
ClassCastException when collect primitive array
URL: https://github.com/apache/flink/pull/21016
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
huyuanfeng2018 commented on PR #21076:
URL: https://github.com/apache/flink/pull/21076#issuecomment-1279878588
> Thanks for your contribution @huyuanfeng2018. I think this pull request
should be merged into master branch rather than release-1.16.
Thanks @WencongLiu , I have switched
sap1ens commented on PR #404:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/404#issuecomment-1279876617
Ran failed test locally, worked fine 路 Could be flaky
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
sap1ens commented on PR #403:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/403#issuecomment-1279862016
Done https://github.com/apache/flink-kubernetes-operator/pull/404
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
sap1ens opened a new pull request, #404:
URL: https://github.com/apache/flink-kubernetes-operator/pull/404
Backporting https://github.com/apache/flink-kubernetes-operator/pull/403 to
the 1.2 release branch.
--
This is an automated message from the Apache Git Service.
To respond to the
gyfora commented on PR #403:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/403#issuecomment-1279825176
@sap1ens could you please open a backport PR against the `release-1.2`
branch based on the merged commit?
--
This is an automated message from the Apache Git Service.
[
https://issues.apache.org/jira/browse/FLINK-29633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-29633.
--
Fix Version/s: kubernetes-operator-1.3.0
Resolution: Fixed
gyfora merged PR #403:
URL: https://github.com/apache/flink-kubernetes-operator/pull/403
--
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:
gyfora commented on code in PR #403:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/403#discussion_r996349881
##
flink-kubernetes-standalone/src/main/java/org/apache/flink/kubernetes/operator/kubeclient/decorators/CmdStandaloneJobManagerDecorator.java:
##
@@
hlteoh37 commented on PR #1:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/1#issuecomment-1279823905
Question for general discussion:
Do we have any thoughts on using conditional expressions? I note that the
`BatchWriteItem` API we are using doesn't support this. Maybe we
sap1ens commented on code in PR #403:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/403#discussion_r996348488
##
flink-kubernetes-standalone/src/main/java/org/apache/flink/kubernetes/operator/kubeclient/decorators/CmdStandaloneJobManagerDecorator.java:
##
@@
hlteoh37 commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/1#discussion_r996348036
##
flink-connector-aws-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSinkBuilder.java:
##
@@ -0,0 +1,134 @@
+/*
+ *
gyfora commented on code in PR #403:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/403#discussion_r996347944
##
flink-kubernetes-standalone/src/main/java/org/apache/flink/kubernetes/operator/kubeclient/decorators/CmdStandaloneJobManagerDecorator.java:
##
@@
gyfora commented on code in PR #403:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/403#discussion_r996347785
##
flink-kubernetes-standalone/src/main/java/org/apache/flink/kubernetes/operator/kubeclient/decorators/CmdStandaloneJobManagerDecorator.java:
##
@@
hlteoh37 commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/1#discussion_r996321025
##
flink-connector-aws-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSink.java:
##
@@ -0,0 +1,162 @@
+/*
+ * Licensed
sap1ens commented on code in PR #403:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/403#discussion_r996346689
##
flink-kubernetes-standalone/src/main/java/org/apache/flink/kubernetes/operator/kubeclient/decorators/CmdStandaloneJobManagerDecorator.java:
##
@@
Samrat Deb created FLINK-29649:
--
Summary: upgrade Maven checkstyle plugin to latest version >= v8.30
Key: FLINK-29649
URL: https://issues.apache.org/jira/browse/FLINK-29649
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-29649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Samrat Deb updated FLINK-29649:
---
Description:
currenly while building project some of the typical warnings related to
checkstyle
gyfora commented on code in PR #403:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/403#discussion_r996327566
##
flink-kubernetes-standalone/src/main/java/org/apache/flink/kubernetes/operator/kubeclient/decorators/CmdStandaloneJobManagerDecorator.java:
##
@@
gyfora commented on code in PR #403:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/403#discussion_r996327486
##
flink-kubernetes-standalone/src/main/java/org/apache/flink/kubernetes/operator/kubeclient/decorators/CmdStandaloneJobManagerDecorator.java:
##
@@
[
https://issues.apache.org/jira/browse/FLINK-20350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17618133#comment-17618133
]
Samrat Deb commented on FLINK-20350:
Hi [~danny.cranmer]
In ticket you have already mentioned
hlteoh37 commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/1#discussion_r996320784
##
flink-connector-aws-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSink.java:
##
@@ -0,0 +1,162 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-29620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17618123#comment-17618123
]
Gyula Fora commented on FLINK-29620:
I think that this might be fixed on 1.2.0 already, could you
ZmmBigdata commented on PR #20983:
URL: https://github.com/apache/flink/pull/20983#issuecomment-1279766335
> @ZmmBigdata Thanks for fixing this! It's better to fix the chinese version
(though it hasn't been translated yet)
`docs/content.zh/docs/dev/table/sql/queries/joins.md`
[
https://issues.apache.org/jira/browse/FLINK-29458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17618116#comment-17618116
]
ZuoYan commented on FLINK-29458:
[~jark]
It has been modified. Please refer to [GitHub Pull Request
WencongLiu commented on PR #21076:
URL: https://github.com/apache/flink/pull/21076#issuecomment-1279753603
Thanks for your contribution @huyuanfeng2018. I think this pull request
should be merged into master branch rather than release-1.16.
--
This is an automated message from the Apache
[
https://issues.apache.org/jira/browse/FLINK-29646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17618104#comment-17618104
]
Wencong Liu commented on FLINK-29646:
-
Thanks [~heigebupahei] . +1 for this change. At present, sql
darenwkt opened a new pull request, #10:
URL: https://github.com/apache/flink-connector-dynamodb/pull/10
Added maven plugin to use in ci workflow for license check.
Note:
- License check current runs on mvn install directory, which will need to be
updated when switched to deploy
darenwkt closed pull request #8: [FLINK-29310] Added license check
URL: https://github.com/apache/flink-connector-dynamodb/pull/8
--
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-10989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17618088#comment-17618088
]
Angelo Kastroulis commented on FLINK-10989:
---
At the very minimum, this should be documented in
zentol commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r996303463
##
docs/content/docs/connectors/datastream/datagen.md:
##
@@ -0,0 +1,115 @@
+---
+title: DataGen
+weight: 3
+type: docs
+---
+
+
+# DataGen Connector
+
+The DataGen
zentol commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r996305134
##
docs/content/docs/connectors/datastream/datagen.md:
##
@@ -0,0 +1,115 @@
+---
+title: DataGen
+weight: 3
+type: docs
+---
+
+
+# DataGen Connector
+
+The DataGen
[
https://issues.apache.org/jira/browse/FLINK-29646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuanfenghu updated FLINK-29646:
---
Priority: Major (was: Critical)
> SQL Gateway should return a simpler error message
>
[
https://issues.apache.org/jira/browse/FLINK-29646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuanfenghu updated FLINK-29646:
---
Priority: Critical (was: Minor)
> SQL Gateway should return a simpler error message
>
zentol commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r996303463
##
docs/content/docs/connectors/datastream/datagen.md:
##
@@ -0,0 +1,115 @@
+---
+title: DataGen
+weight: 3
+type: docs
+---
+
+
+# DataGen Connector
+
+The DataGen
flinkbot commented on PR #21076:
URL: https://github.com/apache/flink/pull/21076#issuecomment-1279741271
## CI report:
* 0a78909554fce3c02ee4ee35df48c0d7dacd6d59 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
zentol commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r996303463
##
docs/content/docs/connectors/datastream/datagen.md:
##
@@ -0,0 +1,115 @@
+---
+title: DataGen
+weight: 3
+type: docs
+---
+
+
+# DataGen Connector
+
+The DataGen
[
https://issues.apache.org/jira/browse/FLINK-29646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29646:
---
Labels: pull-request-available (was: )
> SQL Gateway should return a simpler error message
huyuanfeng2018 opened a new pull request, #21076:
URL: https://github.com/apache/flink/pull/21076
## What is the purpose of the change
this pull request make sql-gateway fetch key error information instead of
return all stack of information, when operation happen error
zentol commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r996303005
##
docs/content/docs/connectors/datastream/datagen.md:
##
@@ -0,0 +1,115 @@
+---
+title: DataGen
+weight: 3
+type: docs
+---
+
+
+# DataGen Connector
+
+The DataGen
afedulov commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r996297824
##
docs/content/docs/connectors/datastream/datagen.md:
##
@@ -0,0 +1,115 @@
+---
+title: DataGen
+weight: 3
+type: docs
+---
+
+
+# DataGen Connector
+
+The DataGen
[
https://issues.apache.org/jira/browse/FLINK-29557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17618052#comment-17618052
]
Aitozi commented on FLINK-29557:
Thanks [~gaoyunhaii] for your reply. The {{OutputFormatProvider}} in
zentol commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r996290206
##
docs/content/docs/connectors/datastream/datagen.md:
##
@@ -0,0 +1,115 @@
+---
+title: DataGen
+weight: 3
+type: docs
+---
+
+
+# DataGen Connector
+
+The DataGen
ashmeet-kandhari commented on PR #20991:
URL: https://github.com/apache/flink/pull/20991#issuecomment-1279718997
> Thanks for your contribution @ashmeet-kandhari As I mentioned in jira
issue we could continue code related discussions here
>
> Could you please share more detail/link
zentol commented on PR #20757:
URL: https://github.com/apache/flink/pull/20757#issuecomment-1279718382
We're running into a bug in the Japicmp plugin; I'll try to resolve that
upstream.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
zentol commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r996284438
##
flink-core/src/main/java/org/apache/flink/api/connector/source/lib/util/IteratorSourceReaderBase.java:
##
@@ -0,0 +1,187 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-29648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Juntao Hu updated FLINK-29648:
--
Priority: Critical (was: Blocker)
> "LocalDateTime not supported" error when retrieving Java
Juntao Hu created FLINK-29648:
-
Summary: "LocalDateTime not supported" error when retrieving Java
TypeInformation from PyFlink
Key: FLINK-29648
URL: https://issues.apache.org/jira/browse/FLINK-29648
[
https://issues.apache.org/jira/browse/FLINK-29608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17618034#comment-17618034
]
Dian Fu edited comment on FLINK-29608 at 10/15/22 7:37 AM:
---
>From the
[
https://issues.apache.org/jira/browse/FLINK-29608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17618034#comment-17618034
]
Dian Fu edited comment on FLINK-29608 at 10/15/22 7:35 AM:
---
>From the
[
https://issues.apache.org/jira/browse/FLINK-29608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17618034#comment-17618034
]
Dian Fu commented on FLINK-29608:
-
>From the exception stack:
```
I don't
> 使用 pyflink1.17dev
53 matches
Mail list logo
