Matthew McMahon created FLINK-17900:
---
Summary: Listener for when Files are committed in StreamingFileSink
Key: FLINK-17900
URL: https://issues.apache.org/jira/browse/FLINK-17900
Project: Flink
caozhen1937 commented on a change in pull request #12296:
URL: https://github.com/apache/flink/pull/12296#discussion_r429596017
##
File path: docs/ops/deployment/native_kubernetes.zh.md
##
@@ -92,73 +90,73 @@ $ ./bin/kubernetes-session.sh \
-Dkubernetes.container.image=
{%
caozhen1937 commented on a change in pull request #12296:
URL: https://github.com/apache/flink/pull/12296#discussion_r429596017
##
File path: docs/ops/deployment/native_kubernetes.zh.md
##
@@ -92,73 +90,73 @@ $ ./bin/kubernetes-session.sh \
-Dkubernetes.container.image=
{%
caozhen1937 commented on a change in pull request #12296:
URL: https://github.com/apache/flink/pull/12296#discussion_r429595609
##
File path: docs/ops/deployment/native_kubernetes.zh.md
##
@@ -92,73 +90,73 @@ $ ./bin/kubernetes-session.sh \
-Dkubernetes.container.image=
{%
caozhen1937 commented on a change in pull request #12296:
URL: https://github.com/apache/flink/pull/12296#discussion_r429595609
##
File path: docs/ops/deployment/native_kubernetes.zh.md
##
@@ -92,73 +90,73 @@ $ ./bin/kubernetes-session.sh \
-Dkubernetes.container.image=
{%
JingsongLi commented on a change in pull request #12283:
URL: https://github.com/apache/flink/pull/12283#discussion_r429594503
##
File path: docs/dev/table/connectors/filesystem.md
##
@@ -0,0 +1,352 @@
+---
+title: "Hadoop FileSystem Connector"
+nav-title: Hadoop FileSystem
[
https://issues.apache.org/jira/browse/FLINK-13733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17115011#comment-17115011
]
Jiangjie Qin commented on FLINK-13733:
--
I am not completely sure what caused the problem. One guess
klion26 commented on a change in pull request #12296:
URL: https://github.com/apache/flink/pull/12296#discussion_r429517344
##
File path: docs/ops/deployment/native_kubernetes.zh.md
##
@@ -24,43 +24,41 @@ specific language governing permissions and limitations
under the
[
https://issues.apache.org/jira/browse/FLINK-17899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-17899:
-
Description:
*Preambel:* This whole discussion is to some extend only necessary, because in
[
https://issues.apache.org/jira/browse/FLINK-17899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-17899:
-
Description:
*Preambel:* This whole discussion is to some extend only necessary, because in
[
https://issues.apache.org/jira/browse/FLINK-17897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen reassigned FLINK-17897:
Assignee: Stephan Ewen (was: Jiangjie Qin)
> Resolve stability annotations discussion
Stephan Ewen created FLINK-17899:
Summary: Integrate FLIP-126 Timestamps and Watermarking with
FLIP-27 sources
Key: FLINK-17899
URL: https://issues.apache.org/jira/browse/FLINK-17899
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-17898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen reassigned FLINK-17898:
Assignee: Stephan Ewen
> Remove Exceptions from signatures of SourceOutput methods
>
[
https://issues.apache.org/jira/browse/FLINK-17898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-17898:
-
Description:
The {{collect(...)}} methods in {{SourceOutput}} currently declare that they
can
[
https://issues.apache.org/jira/browse/FLINK-17898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-17898:
-
Priority: Blocker (was: Major)
> Remove Exceptions from signatures of SourceOutput methods
>
Stephan Ewen created FLINK-17898:
Summary: Remove Exceptions from signatures of SourceOutput methods
Key: FLINK-17898
URL: https://issues.apache.org/jira/browse/FLINK-17898
Project: Flink
Stephan Ewen created FLINK-17897:
Summary: Resolve stability annotations discussion for FLIP-27 in
1.11
Key: FLINK-17897
URL: https://issues.apache.org/jira/browse/FLINK-17897
Project: Flink
zhijiangW opened a new pull request #12302:
URL: https://github.com/apache/flink/pull/12302
## What is the purpose of the change
Fix the checkstyle issue of missing a javadoc comment in DummyNoOpOperator,
which would break the creation of release-1.11-rc1.
## Brief change log
zhijiangW merged pull request #12302:
URL: https://github.com/apache/flink/pull/12302
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
flinkbot edited a comment on pull request #12301:
URL: https://github.com/apache/flink/pull/12301#issuecomment-633042244
## CI report:
* a3b8f38cc685f05413dde8016aa1714ac1742e20 Azure:
[
https://issues.apache.org/jira/browse/FLINK-17820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17114859#comment-17114859
]
Stephan Ewen commented on FLINK-17820:
--
Regarding changing the behavior of
[
https://issues.apache.org/jira/browse/FLINK-17820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17114849#comment-17114849
]
Stephan Ewen commented on FLINK-17820:
--
I see. You cannot rely on {{close()}} here as well, because
[
https://issues.apache.org/jira/browse/FLINK-17470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17114846#comment-17114846
]
Stephan Ewen commented on FLINK-17470:
--
Have you run Flink 1.9 on the exact same version? And does
StephanEwen commented on pull request #12035:
URL: https://github.com/apache/flink/pull/12035#issuecomment-633078631
Thank you for looking into the test.
Unfortunately, this PR now contains a very large amount of unrelated code
format changes and we cannot review or merge it like
[
https://issues.apache.org/jira/browse/FLINK-17854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-17854.
> Use InputStatus directly in user-facing async input APIs (like source readers)
>
[
https://issues.apache.org/jira/browse/FLINK-17854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-17854.
--
Resolution: Fixed
Fixed in 1.11.0 via
- 17d3f05ff5d2c286610386e751cafaf4837b2151
-
StephanEwen commented on pull request #12271:
URL: https://github.com/apache/flink/pull/12271#issuecomment-633076719
Manually merged in d0f9892c58fdb819dc66737b49d7a1f04dde2036
This is an automated message from the Apache
StephanEwen closed pull request #12271:
URL: https://github.com/apache/flink/pull/12271
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
StephanEwen commented on pull request #11196:
URL: https://github.com/apache/flink/pull/11196#issuecomment-633076862
Closing this in favor of an approach based on a cleanup hook.
This is an automated message from the Apache
StephanEwen closed pull request #11196:
URL: https://github.com/apache/flink/pull/11196
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
StephanEwen commented on pull request #12271:
URL: https://github.com/apache/flink/pull/12271#issuecomment-633076233
Thank you for reviewing this.
Merging...
This is an automated message from the Apache Git Service.
To
[
https://issues.apache.org/jira/browse/FLINK-16468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17114792#comment-17114792
]
Gary Yao commented on FLINK-16468:
--
[~longtimer] No problem, take care!
> BlobClient rapid retrieval
flinkbot edited a comment on pull request #12301:
URL: https://github.com/apache/flink/pull/12301#issuecomment-633042244
## CI report:
* a3b8f38cc685f05413dde8016aa1714ac1742e20 Azure:
flinkbot commented on pull request #12301:
URL: https://github.com/apache/flink/pull/12301#issuecomment-633042244
## CI report:
* a3b8f38cc685f05413dde8016aa1714ac1742e20 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
[
https://issues.apache.org/jira/browse/FLINK-16572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17114716#comment-17114716
]
Richard Deurwaarder commented on FLINK-16572:
-
Apologies for the delay [~rmetzger], I had
flinkbot commented on pull request #12301:
URL: https://github.com/apache/flink/pull/12301#issuecomment-633035319
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the
Xeli closed pull request #12300:
URL: https://github.com/apache/flink/pull/12300
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
Xeli opened a new pull request #12301:
URL: https://github.com/apache/flink/pull/12301
This MR adds some extra logging to pubsub e2e test.
Because it's quite hard to reproduce locally we want to try and see what
these extra logs tells us when it naturally happens again on azure.
flinkbot commented on pull request #12300:
URL: https://github.com/apache/flink/pull/12300#issuecomment-633032908
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the
Xeli opened a new pull request #12300:
URL: https://github.com/apache/flink/pull/12300
This MR adds some extra logging to pubsub e2e test.
Because it's quite hard to reproduce locally we want to try and see what
these extra logs tells us when it naturally happens again on azure.
[
https://issues.apache.org/jira/browse/FLINK-17303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng closed FLINK-17303.
---
Resolution: Resolved
> Return TableResult for Python TableEnvironment
>
[
https://issues.apache.org/jira/browse/FLINK-17303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17114639#comment-17114639
]
Hequn Cheng commented on FLINK-17303:
-
Resolved in 1.12.0 via
hequn8128 closed pull request #12246:
URL: https://github.com/apache/flink/pull/12246
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
[
https://issues.apache.org/jira/browse/FLINK-17891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17114622#comment-17114622
]
Shangwen Tang commented on FLINK-17891:
---
Hi [~lzljs3620320] [~jark] , Can you assign this task to
KurtYoung commented on a change in pull request #12283:
URL: https://github.com/apache/flink/pull/12283#discussion_r429526249
##
File path: docs/dev/table/connectors/filesystem.md
##
@@ -0,0 +1,352 @@
+---
+title: "Hadoop FileSystem Connector"
+nav-title: Hadoop FileSystem
[
https://issues.apache.org/jira/browse/FLINK-17883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17114597#comment-17114597
]
Dian Fu commented on FLINK-17883:
-
[~nicholasjiang] Yes, I think so. It should have been supported in
flinkbot edited a comment on pull request #12293:
URL: https://github.com/apache/flink/pull/12293#issuecomment-632624268
## CI report:
* 3d58b38f7bf87bfb660b7c24adb90ada3d077e20 Azure:
flinkbot edited a comment on pull request #12299:
URL: https://github.com/apache/flink/pull/12299#issuecomment-632977800
## CI report:
* 6c0db10514575ddaeb66689ff7b3e2ee2975bdfe Azure:
48 matches
Mail list logo
