Huang Xingbo created FLINK-15913:
Summary: Add Python Table Function Runner And Operator
Key: FLINK-15913
URL: https://issues.apache.org/jira/browse/FLINK-15913
Project: Flink
Issue Type: New
[
https://issues.apache.org/jira/browse/FLINK-15909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng reassigned FLINK-15909:
---
Assignee: Wei Zhong
> Add PyPI release process into the subsequent release of 1.9.x
>
[
https://issues.apache.org/jira/browse/FLINK-15908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng reassigned FLINK-15908:
---
Assignee: Wei Zhong
> Add description of support 'pip install' to 1.9.x documents
> ---
dawidwys closed pull request #10915: [FLINK-15706][table-planner-blink]
LastValueAggFunctionWithOrderTest compilation error due to incompatible types
URL: https://github.com/apache/flink/pull/10915
This is an automated messa
[
https://issues.apache.org/jira/browse/FLINK-15841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17030422#comment-17030422
]
Aljoscha Krettek commented on FLINK-15841:
--
Sure yes, that would be good. 👌
Â
StephanEwen opened a new pull request #11018: [FLINK-15905][runtime] Fix race
condition between allocation and release of OpaqueMemoryResource
URL: https://github.com/apache/flink/pull/11018
## What is the purpose of the change
Fixes the race condition when releasing `OpaqueMemoryRes
[
https://issues.apache.org/jira/browse/FLINK-15905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-15905:
---
Labels: pull-request-available (was: )
> Fix Race Condition when releasing shared memory re
[
https://issues.apache.org/jira/browse/FLINK-15706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz closed FLINK-15706.
Resolution: Fixed
Fixed in
master: e0afec8a7654334e3e9992433f5a0424d2ed51b8
b3c86a81161e5
[
https://issues.apache.org/jira/browse/FLINK-15706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17030427#comment-17030427
]
Dawid Wysakowicz commented on FLINK-15706:
--
Please reopen if you see this reocc
[
https://issues.apache.org/jira/browse/FLINK-15913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo updated FLINK-15913:
-
Parent: FLINK-14500
Issue Type: Sub-task (was: New Feature)
> Add Python Table Function
flinkbot commented on issue #11018: [FLINK-15905][runtime] Fix race condition
between allocation and release of OpaqueMemoryResource
URL: https://github.com/apache/flink/pull/11018#issuecomment-582288319
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I h
[
https://issues.apache.org/jira/browse/FLINK-15706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17030426#comment-17030426
]
Dawid Wysakowicz commented on FLINK-15706:
--
The fix restructured the tests in a
aljoscha commented on issue #11007: [FLINK-15872][javadoc] Remove unnessary
javadocs in InputFormat
URL: https://github.com/apache/flink/pull/11007#issuecomment-582289515
Perfect, thanks! I'm merging. The test failure is a known instability.
[
https://issues.apache.org/jira/browse/FLINK-15872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-15872.
Fix Version/s: 1.11.0
Resolution: Fixed
master:Â 09056477c45b482fcbd4437750fa3eb9e1d
aljoscha merged pull request #11007: [FLINK-15872][javadoc] Remove unnessary
javadocs in InputFormat
URL: https://github.com/apache/flink/pull/11007
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/FLINK-15913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo updated FLINK-15913:
-
Description:
This Jira will include two PRs:
* Add Python Table Function Runner and Operator in
[
https://issues.apache.org/jira/browse/FLINK-15740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17030433#comment-17030433
]
Aljoscha Krettek commented on FLINK-15740:
--
Turns out this is not as easy, {{Th
aljoscha commented on issue #4228: Flink-7035 Automatically identify AWS
Region, simplified constructors, added test properties support
URL: https://github.com/apache/flink/pull/4228#issuecomment-582292746
@tweise Do you think this one is still relevant? You guys must have the most
Kinesis
flinkbot edited a comment on issue #11006: [FLINK-15868][kinesis] Resolve
version conflict between jackson-core and jackson-dataformat-cbor
URL: https://github.com/apache/flink/pull/11006#issuecomment-581673930
## CI report:
* af2a640e770f0fff302ec8d3b8920895a3f40bfb Travis:
[SU
flinkbot commented on issue #11018: [FLINK-15905][runtime] Fix race condition
between allocation and release of OpaqueMemoryResource
URL: https://github.com/apache/flink/pull/11018#issuecomment-582293770
## CI report:
* 4ea977f18fb6bd5da47b80f96d899ef5d05193a4 UNKNOWN
[
https://issues.apache.org/jira/browse/FLINK-15910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-15910:
Summary: Add NOTICE and LICENSE files for Stateful Functions (was: Add
NOTICE fil
aljoscha commented on issue #11017: [FLINK-15907] [runtime] [configuration]
expose getRawValue as protect…
URL: https://github.com/apache/flink/pull/11017#issuecomment-582294418
@dawidwys What do you think about this one? I'm skeptical because making the
method `protected` increases the AP
zhijiang created FLINK-15914:
Summary: Miss the barrier alignment metric for the case of two
inputs
Key: FLINK-15914
URL: https://issues.apache.org/jira/browse/FLINK-15914
Project: Flink
Issue T
[
https://issues.apache.org/jira/browse/FLINK-15908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng reassigned FLINK-15908:
---
Assignee: Wei Zhong (was: li412076173)
> Add description of support 'pip install' to 1.9.x
rkhachatryan commented on a change in pull request #10151: [FLINK-14231] Handle
the pending processing-time timers to make endInput semantics on the operator
chain strict
URL: https://github.com/apache/flink/pull/10151#discussion_r375118760
##
File path:
flink-streaming-java/src/m
[
https://issues.apache.org/jira/browse/FLINK-15909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng reassigned FLINK-15909:
---
Assignee: Wei Zhong (was: li412076173)
> Add PyPI release process into the subsequent rele
[
https://issues.apache.org/jira/browse/FLINK-15811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17030448#comment-17030448
]
Aljoscha Krettek commented on FLINK-15811:
--
This changed since the test was add
[
https://issues.apache.org/jira/browse/FLINK-15740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17030450#comment-17030450
]
Chesnay Schepler edited comment on FLINK-15740 at 2/5/20 8:42 AM:
[
https://issues.apache.org/jira/browse/FLINK-15740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17030450#comment-17030450
]
Chesnay Schepler commented on FLINK-15740:
--
The obvious workaround being to ret
[
https://issues.apache.org/jira/browse/FLINK-15811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17030451#comment-17030451
]
Aljoscha Krettek commented on FLINK-15811:
--
If the {{InfiniteSource}} that is u
dawidwys commented on issue #11017: [FLINK-15907] [runtime] [configuration]
expose getRawValue as protect…
URL: https://github.com/apache/flink/pull/11017#issuecomment-582302171
I agree with you in principle. I am also sceptical about this change for the
same reasons. My take is that `Conf
flinkbot commented on issue #4228: Flink-7035 Automatically identify AWS
Region, simplified constructors, added test properties support
URL: https://github.com/apache/flink/pull/4228#issuecomment-582303009
## CI report:
* 9afa9fb8160db3bbebd7bef60d888a9de1a6e72b UNKNOWN
zentol merged pull request #10959: [FLINK-15335] Replace
`add-dependencies-for-IDEA` profile
URL: https://github.com/apache/flink/pull/10959
This is an automated message from the Apache Git Service.
To respond to the message
carp84 commented on a change in pull request #11018: [FLINK-15905][runtime] Fix
race condition between allocation and release of OpaqueMemoryResource
URL: https://github.com/apache/flink/pull/11018#discussion_r375111995
##
File path:
flink-runtime/src/main/java/org/apache/flink/run
carp84 commented on a change in pull request #11018: [FLINK-15905][runtime] Fix
race condition between allocation and release of OpaqueMemoryResource
URL: https://github.com/apache/flink/pull/11018#discussion_r375122419
##
File path:
flink-runtime/src/main/java/org/apache/flink/run
twalthr closed pull request #10960: [FLINK-15487][table] Update code generation
for new type inference
URL: https://github.com/apache/flink/pull/10960
This is an automated message from the Apache Git Service.
To respond to t
[
https://issues.apache.org/jira/browse/FLINK-15335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-15335.
Resolution: Fixed
master: 73017a82d9c13a16b42e5025d5922eb746dd458d
1.10: 4df788ae81e6ed18c
[
https://issues.apache.org/jira/browse/FLINK-15487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-15487.
Fix Version/s: 1.11.0
Resolution: Fixed
Fixed in 1.11:
[FLINK-15487][table] Update code gen
flinkbot edited a comment on issue #11018: [FLINK-15905][runtime] Fix race
condition between allocation and release of OpaqueMemoryResource
URL: https://github.com/apache/flink/pull/11018#issuecomment-582293770
## CI report:
* 4ea977f18fb6bd5da47b80f96d899ef5d05193a4 Travis:
[PE
[
https://issues.apache.org/jira/browse/FLINK-15914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao updated FLINK-15914:
-
Affects Version/s: 1.10.0
> Miss the barrier alignment metric for the case of two inputs
> -
[
https://issues.apache.org/jira/browse/FLINK-15914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao updated FLINK-15914:
-
Priority: Critical (was: Major)
> Miss the barrier alignment metric for the case of two inputs
> --
[
https://issues.apache.org/jira/browse/FLINK-15914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao updated FLINK-15914:
-
Fix Version/s: 1.10.0
> Miss the barrier alignment metric for the case of two inputs
> -
StephanEwen commented on a change in pull request #11018:
[FLINK-15905][runtime] Fix race condition between allocation and release of
OpaqueMemoryResource
URL: https://github.com/apache/flink/pull/11018#discussion_r375133066
##
File path:
flink-runtime/src/main/java/org/apache/fli
[
https://issues.apache.org/jira/browse/FLINK-15811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-15811:
-
Component/s: (was: API / DataStream)
Runtime / Task
> StreamSourceO
[
https://issues.apache.org/jira/browse/FLINK-15811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17030469#comment-17030469
]
Aljoscha Krettek commented on FLINK-15811:
--
This commit introduced the problem:
zhijiangW opened a new pull request #11019:
[FLINK-15914][checkpointing][metrics] Miss the barrier alignment metric for the
case of two inputs
URL: https://github.com/apache/flink/pull/11019
## What is the purpose of the change
When the `StreamTwoInputSelectableProcessor` was introd
[
https://issues.apache.org/jira/browse/FLINK-15914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-15914:
---
Labels: pull-request-available (was: )
> Miss the barrier alignment metric for the case of
flinkbot commented on issue #11019: [FLINK-15914][checkpointing][metrics] Miss
the barrier alignment metric for the case of two inputs
URL: https://github.com/apache/flink/pull/11019#issuecomment-582312163
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I
[
https://issues.apache.org/jira/browse/FLINK-15698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-15698.
> Restructure Configuration Docs to separate "Getting Started", "Common
> Operations" and "Tuning/Deb
[
https://issues.apache.org/jira/browse/FLINK-15698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-15698.
--
Fix Version/s: (was: 1.11.0)
1.10.0
Resolution: Fixed
Fixed in
[
https://issues.apache.org/jira/browse/FLINK-15695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-15695.
> Remove outdated section of Configuration Page
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-15695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-15695.
--
Resolution: Fixed
Fixed in
- 1.10.0 via 5729f237d2c3f01efc3ebc70d051bec09381fcc8
- master
[
https://issues.apache.org/jira/browse/FLINK-15696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-15696.
> Update description of "RocksDB Configurable Options" for new options
> -
[
https://issues.apache.org/jira/browse/FLINK-15696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-15696.
--
Assignee: Stephan Ewen
Resolution: Fixed
Fixed in
- 1.10.0 via a9040e79e7fff2acec3a921
Timo Walther created FLINK-15915:
Summary: Bump Jackson to 2.10.1 in flink-table-planner
Key: FLINK-15915
URL: https://issues.apache.org/jira/browse/FLINK-15915
Project: Flink
Issue Type: Bug
flinkbot edited a comment on issue #4228: Flink-7035 Automatically identify AWS
Region, simplified constructors, added test properties support
URL: https://github.com/apache/flink/pull/4228#issuecomment-582303009
## CI report:
* 9afa9fb8160db3bbebd7bef60d888a9de1a6e72b Travis:
[
[
https://issues.apache.org/jira/browse/FLINK-15824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-15824.
> Generalize CommonOption to support other option groups as well
> ---
[
https://issues.apache.org/jira/browse/FLINK-15824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-15824.
--
Fix Version/s: 1.10.0
Resolution: Implemented
Implemented in
1.10.0 via
- e811d13251
pnowojski commented on a change in pull request #11019:
[FLINK-15914][checkpointing][metrics] Miss the barrier alignment metric for the
case of two inputs
URL: https://github.com/apache/flink/pull/11019#discussion_r375140363
##
File path:
flink-streaming-java/src/main/java/org/apa
aljoscha commented on issue #11017: [FLINK-15907] [runtime] [configuration]
expose getRawValue as protect…
URL: https://github.com/apache/flink/pull/11017#issuecomment-582316387
To make things easier, we could make the method protected but mark it as
`@Internal`, meaning that we can still
pnowojski commented on a change in pull request #11019:
[FLINK-15914][checkpointing][metrics] Miss the barrier alignment metric for the
case of two inputs
URL: https://github.com/apache/flink/pull/11019#discussion_r375139240
##
File path:
flink-streaming-java/src/main/java/org/apa
[
https://issues.apache.org/jira/browse/FLINK-15697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-15697.
> Remove Options that are not configured in "flink-conf.yaml" from
> Configuration Docs
> ---
[
https://issues.apache.org/jira/browse/FLINK-15697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-15697.
--
Fix Version/s: 1.10.0
Resolution: Fixed
Fixed in
1.10.0 via
- e4ede3f6e8c7e0ad771ec3
[
https://issues.apache.org/jira/browse/FLINK-15911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-15911:
-
Priority: Blocker (was: Major)
> Flink does not work over NAT
>
>
[
https://issues.apache.org/jira/browse/FLINK-15683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-15683.
> Restructure Configuration Docs
> --
>
> Key: FLINK-15683
[
https://issues.apache.org/jira/browse/FLINK-15683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-15683.
--
Assignee: Stephan Ewen
Resolution: Fixed
Fixed via resolution of all subtasks.
> Restru
[
https://issues.apache.org/jira/browse/FLINK-15853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17030491#comment-17030491
]
Timo Walther commented on FLINK-15853:
--
FYI: I would wait a little bit with updatin
flinkbot edited a comment on issue #11018: [FLINK-15905][runtime] Fix race
condition between allocation and release of OpaqueMemoryResource
URL: https://github.com/apache/flink/pull/11018#issuecomment-582293770
## CI report:
* 4ea977f18fb6bd5da47b80f96d899ef5d05193a4 Travis:
[FA
flinkbot commented on issue #11019: [FLINK-15914][checkpointing][metrics] Miss
the barrier alignment metric for the case of two inputs
URL: https://github.com/apache/flink/pull/11019#issuecomment-582319661
## CI report:
* 012203b66328bc46e9af4d37c585521915f450ca UNKNOWN
igalshilman commented on issue #12: [FLINK-15899] [build] Inherit from Apache
Parent POM
URL: https://github.com/apache/flink-statefun/pull/12#issuecomment-582322537
Thanks @tzulitai !
Can you check if spotless can be configured to conform with that java doc
style?
sunhaibotb commented on a change in pull request #10151: [FLINK-14231] Handle
the pending processing-time timers to make endInput semantics on the operator
chain strict
URL: https://github.com/apache/flink/pull/10151#discussion_r375149637
##
File path:
flink-streaming-java/src/mai
[
https://issues.apache.org/jira/browse/FLINK-15915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-15915.
Resolution: Duplicate
Will be fixed as part of FLINK-15868.
> Bump Jackson to 2.10.1 in flink-tab
zhijiangW commented on a change in pull request #11019:
[FLINK-15914][checkpointing][metrics] Miss the barrier alignment metric for the
case of two inputs
URL: https://github.com/apache/flink/pull/11019#discussion_r375152356
##
File path:
flink-streaming-java/src/main/java/org/apa
twalthr commented on issue #10981: [hotfix][table] Convert
FlinkCalciteSqlValidator to Java
URL: https://github.com/apache/flink/pull/10981#issuecomment-582325828
Master was broken at that time need to rerun Travis.
@flinkbot run travis
--
[
https://issues.apache.org/jira/browse/FLINK-15811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-15811:
--
Summary: StreamSourceOperatorWatermarksTest.testNoMaxWatermarkOnAsyncCancel
fails on Travis (
zhijiangW commented on a change in pull request #11019:
[FLINK-15914][checkpointing][metrics] Miss the barrier alignment metric for the
case of two inputs
URL: https://github.com/apache/flink/pull/11019#discussion_r375154315
##
File path:
flink-streaming-java/src/main/java/org/apa
zhijiangW commented on a change in pull request #11019:
[FLINK-15914][checkpointing][metrics] Miss the barrier alignment metric for the
case of two inputs
URL: https://github.com/apache/flink/pull/11019#discussion_r375154315
##
File path:
flink-streaming-java/src/main/java/org/apa
zhijiangW commented on a change in pull request #11019:
[FLINK-15914][checkpointing][metrics] Miss the barrier alignment metric for the
case of two inputs
URL: https://github.com/apache/flink/pull/11019#discussion_r375154631
##
File path:
flink-streaming-java/src/main/java/org/apa
[
https://issues.apache.org/jira/browse/FLINK-15811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17030500#comment-17030500
]
Till Rohrmann commented on FLINK-15811:
---
Another instance: https://api.travis-ci.o
zentol commented on a change in pull request #10993: [FLINK-15845][e2e] Added
java-based StreamingFileSinkTest.
URL: https://github.com/apache/flink/pull/10993#discussion_r375152283
##
File path:
flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/te
zentol commented on a change in pull request #10993: [FLINK-15845][e2e] Added
java-based StreamingFileSinkTest.
URL: https://github.com/apache/flink/pull/10993#discussion_r375136323
##
File path:
flink-end-to-end-tests/flink-end-to-end-tests-common-s3/src/main/java/org/apache/flink
zentol commented on a change in pull request #10993: [FLINK-15845][e2e] Added
java-based StreamingFileSinkTest.
URL: https://github.com/apache/flink/pull/10993#discussion_r375150750
##
File path:
flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/te
zentol commented on a change in pull request #10993: [FLINK-15845][e2e] Added
java-based StreamingFileSinkTest.
URL: https://github.com/apache/flink/pull/10993#discussion_r375136004
##
File path:
flink-end-to-end-tests/flink-end-to-end-tests-common-s3/src/main/java/org/apache/flink
zentol commented on a change in pull request #10993: [FLINK-15845][e2e] Added
java-based StreamingFileSinkTest.
URL: https://github.com/apache/flink/pull/10993#discussion_r375154599
##
File path:
flink-end-to-end-tests/flink-streaming-file-sink-test/src/test/resources/log4j-test.pr
zentol commented on a change in pull request #10993: [FLINK-15845][e2e] Added
java-based StreamingFileSinkTest.
URL: https://github.com/apache/flink/pull/10993#discussion_r375135147
##
File path:
flink-end-to-end-tests/flink-end-to-end-tests-common-s3/src/main/java/org/apache/flink
zentol commented on a change in pull request #10993: [FLINK-15845][e2e] Added
java-based StreamingFileSinkTest.
URL: https://github.com/apache/flink/pull/10993#discussion_r375134537
##
File path:
flink-end-to-end-tests/flink-end-to-end-tests-common-s3/src/main/java/org/apache/flink
zentol commented on a change in pull request #10993: [FLINK-15845][e2e] Added
java-based StreamingFileSinkTest.
URL: https://github.com/apache/flink/pull/10993#discussion_r375150956
##
File path:
flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/te
zentol commented on a change in pull request #10993: [FLINK-15845][e2e] Added
java-based StreamingFileSinkTest.
URL: https://github.com/apache/flink/pull/10993#discussion_r375144972
##
File path:
flink-end-to-end-tests/flink-streaming-file-sink-test/src/test/java/org/apache/flink/t
zentol commented on a change in pull request #10993: [FLINK-15845][e2e] Added
java-based StreamingFileSinkTest.
URL: https://github.com/apache/flink/pull/10993#discussion_r375149437
##
File path:
flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/te
zentol commented on a change in pull request #10993: [FLINK-15845][e2e] Added
java-based StreamingFileSinkTest.
URL: https://github.com/apache/flink/pull/10993#discussion_r375142611
##
File path:
flink-end-to-end-tests/flink-streaming-file-sink-test/src/test/java/org/apache/flink/t
zentol commented on a change in pull request #10993: [FLINK-15845][e2e] Added
java-based StreamingFileSinkTest.
URL: https://github.com/apache/flink/pull/10993#discussion_r375143604
##
File path:
flink-end-to-end-tests/flink-streaming-file-sink-test/src/test/java/org/apache/flink/t
zentol commented on a change in pull request #10993: [FLINK-15845][e2e] Added
java-based StreamingFileSinkTest.
URL: https://github.com/apache/flink/pull/10993#discussion_r375144702
##
File path:
flink-end-to-end-tests/flink-streaming-file-sink-test/src/test/java/org/apache/flink/t
zentol commented on a change in pull request #10993: [FLINK-15845][e2e] Added
java-based StreamingFileSinkTest.
URL: https://github.com/apache/flink/pull/10993#discussion_r375141951
##
File path:
flink-end-to-end-tests/flink-streaming-file-sink-test/src/test/java/org/apache/flink/t
zentol commented on a change in pull request #10993: [FLINK-15845][e2e] Added
java-based StreamingFileSinkTest.
URL: https://github.com/apache/flink/pull/10993#discussion_r375148829
##
File path:
flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/te
zentol commented on a change in pull request #10993: [FLINK-15845][e2e] Added
java-based StreamingFileSinkTest.
URL: https://github.com/apache/flink/pull/10993#discussion_r375142000
##
File path:
flink-end-to-end-tests/flink-streaming-file-sink-test/src/test/java/org/apache/flink/t
zentol commented on a change in pull request #10993: [FLINK-15845][e2e] Added
java-based StreamingFileSinkTest.
URL: https://github.com/apache/flink/pull/10993#discussion_r375140867
##
File path:
flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/te
zentol commented on a change in pull request #10993: [FLINK-15845][e2e] Added
java-based StreamingFileSinkTest.
URL: https://github.com/apache/flink/pull/10993#discussion_r375154401
##
File path: flink-end-to-end-tests/flink-streaming-file-sink-test/pom.xml
##
@@ -36,10 +3
[
https://issues.apache.org/jira/browse/FLINK-15811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-15811:
--
Fix Version/s: 1.11.0
> StreamSourceOperatorWatermarksTest.testNoMaxWatermarkOnAsyncCancel fai
[
https://issues.apache.org/jira/browse/FLINK-15811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17030503#comment-17030503
]
Till Rohrmann commented on FLINK-15811:
---
Another instance: https://api.travis-ci.o
[
https://issues.apache.org/jira/browse/FLINK-15811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-15811:
--
Labels: test-stability (was: )
> StreamSourceOperatorWatermarksTest.testNoMaxWatermarkOnAsync
1 - 100 of 487 matches
Mail list logo