[
https://issues.apache.org/jira/browse/FLINK-10632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16668975#comment-16668975
]
ASF GitHub Bot commented on FLINK-10632:
tillrohrmann commented on a change in p
[
https://issues.apache.org/jira/browse/FLINK-10632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16668971#comment-16668971
]
ASF GitHub Bot commented on FLINK-10632:
tillrohrmann commented on a change in p
[
https://issues.apache.org/jira/browse/FLINK-10632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16668973#comment-16668973
]
ASF GitHub Bot commented on FLINK-10632:
tillrohrmann commented on a change in p
[
https://issues.apache.org/jira/browse/FLINK-10632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16668966#comment-16668966
]
ASF GitHub Bot commented on FLINK-10632:
tillrohrmann commented on a change in p
[
https://issues.apache.org/jira/browse/FLINK-10632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16668970#comment-16668970
]
ASF GitHub Bot commented on FLINK-10632:
tillrohrmann commented on a change in p
[
https://issues.apache.org/jira/browse/FLINK-10712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16668964#comment-16668964
]
Yun Tang commented on FLINK-10712:
--
We have refactored _FailoverRegion.java_ to support
tillrohrmann commented on a change in pull request #6943: [FLINK-10632][e2e]
Running general purpose testing job with failure in per-job mode
URL: https://github.com/apache/flink/pull/6943#discussion_r229376944
##
File path:
flink-end-to-end-tests/test-scripts/test_ha_per_job_clust
tillrohrmann commented on a change in pull request #6943: [FLINK-10632][e2e]
Running general purpose testing job with failure in per-job mode
URL: https://github.com/apache/flink/pull/6943#discussion_r229344187
##
File path:
flink-end-to-end-tests/test-scripts/test_ha_per_job_clust
tillrohrmann commented on a change in pull request #6943: [FLINK-10632][e2e]
Running general purpose testing job with failure in per-job mode
URL: https://github.com/apache/flink/pull/6943#discussion_r229353357
##
File path:
flink-end-to-end-tests/test-scripts/test_ha_per_job_clust
tillrohrmann commented on a change in pull request #6943: [FLINK-10632][e2e]
Running general purpose testing job with failure in per-job mode
URL: https://github.com/apache/flink/pull/6943#discussion_r229343747
##
File path: flink-end-to-end-tests/test-scripts/test_ha_dataset.sh
##
tillrohrmann commented on a change in pull request #6943: [FLINK-10632][e2e]
Running general purpose testing job with failure in per-job mode
URL: https://github.com/apache/flink/pull/6943#discussion_r229353456
##
File path:
flink-end-to-end-tests/test-scripts/test_ha_per_job_clust
tillrohrmann commented on a change in pull request #6943: [FLINK-10632][e2e]
Running general purpose testing job with failure in per-job mode
URL: https://github.com/apache/flink/pull/6943#discussion_r229353255
##
File path:
flink-end-to-end-tests/test-scripts/test_ha_per_job_clust
tillrohrmann commented on a change in pull request #6943: [FLINK-10632][e2e]
Running general purpose testing job with failure in per-job mode
URL: https://github.com/apache/flink/pull/6943#discussion_r229352991
##
File path:
flink-end-to-end-tests/test-scripts/test_ha_per_job_clust
tillrohrmann commented on a change in pull request #6943: [FLINK-10632][e2e]
Running general purpose testing job with failure in per-job mode
URL: https://github.com/apache/flink/pull/6943#discussion_r229343984
##
File path: flink-end-to-end-tests/test-scripts/test_ha_datastream.sh
tillrohrmann commented on a change in pull request #6943: [FLINK-10632][e2e]
Running general purpose testing job with failure in per-job mode
URL: https://github.com/apache/flink/pull/6943#discussion_r229346067
##
File path:
flink-end-to-end-tests/test-scripts/test_ha_per_job_clust
tillrohrmann commented on a change in pull request #6943: [FLINK-10632][e2e]
Running general purpose testing job with failure in per-job mode
URL: https://github.com/apache/flink/pull/6943#discussion_r229358923
##
File path:
flink-end-to-end-tests/test-scripts/test_ha_per_job_clust
[
https://issues.apache.org/jira/browse/FLINK-10713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16668961#comment-16668961
]
Aljoscha Krettek commented on FLINK-10713:
--
Isn't this a blocker?
> RestartInd
[
https://issues.apache.org/jira/browse/FLINK-10712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16668962#comment-16668962
]
Aljoscha Krettek commented on FLINK-10712:
--
Isn't this a blocker?
> RestartPip
[
https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16668936#comment-16668936
]
ASF GitHub Bot commented on FLINK-10600:
yanghua commented on issue #6924: [FLIN
yanghua commented on issue #6924: [FLINK-10600] Provide End-to-end test cases
for modern Kafka connectors
URL: https://github.com/apache/flink/pull/6924#issuecomment-434361242
> shell function `get_partition_end_offset` in kafka-common.sh :
>
> ```
> $KAFKA_DIR/bin/kafka-consumer-
[
https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16668926#comment-16668926
]
ASF GitHub Bot commented on FLINK-10600:
yanghua edited a comment on issue #6924
[
https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16668929#comment-16668929
]
ASF GitHub Bot commented on FLINK-10600:
yanghua edited a comment on issue #6924
[
https://issues.apache.org/jira/browse/FLINK-10203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16668928#comment-16668928
]
ASF GitHub Bot commented on FLINK-10203:
art4ul commented on issue #6608: [FLINK
yanghua edited a comment on issue #6924: [FLINK-10600] Provide End-to-end test
cases for modern Kafka connectors
URL: https://github.com/apache/flink/pull/6924#issuecomment-434358753
@pnowojski I have debugged locally, and the new changes have fixed the shell
error. Before fixing, even if
art4ul commented on issue #6608: [FLINK-10203]Support truncate method for old
Hadoop versions in HadoopRecoverableFsDataOutputStream
URL: https://github.com/apache/flink/pull/6608#issuecomment-434359231
@StephanEwen I really like your idea regarding recoverable writer with
"Recover for res
yanghua edited a comment on issue #6924: [FLINK-10600] Provide End-to-end test
cases for modern Kafka connectors
URL: https://github.com/apache/flink/pull/6924#issuecomment-434358753
@pnowojski I have debugged locally, and the new changes have fixed the shell
error. Before fixing, even if
[
https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16668924#comment-16668924
]
ASF GitHub Bot commented on FLINK-10600:
yanghua commented on issue #6924: [FLIN
yanghua commented on issue #6924: [FLINK-10600] Provide End-to-end test cases
for modern Kafka connectors
URL: https://github.com/apache/flink/pull/6924#issuecomment-434358753
@pnowojski I have debugged locally, and the new changes have fixed the shell
error. Before fixing, even if I do no
[
https://issues.apache.org/jira/browse/FLINK-10638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16668910#comment-16668910
]
ASF GitHub Bot commented on FLINK-10638:
pnowojski commented on issue #6893: [FL
[
https://issues.apache.org/jira/browse/FLINK-10638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16668911#comment-16668911
]
ASF GitHub Bot commented on FLINK-10638:
pnowojski closed pull request #6893: [F
[
https://issues.apache.org/jira/browse/FLINK-10704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16668909#comment-16668909
]
vinoyang commented on FLINK-10704:
--
[~pnowojski] The keyword `ERROR` means an error log
pnowojski commented on issue #6893: [FLINK-10638] [table] Fix table scan
resolution for temporal join queries
URL: https://github.com/apache/flink/pull/6893#issuecomment-434355575
Closing since this is not a valid fix for the problem. Depending on use case
either `optimizeConvertTableRefer
pnowojski closed pull request #6893: [FLINK-10638] [table] Fix table scan
resolution for temporal join queries
URL: https://github.com/apache/flink/pull/6893
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of pro
[
https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16668906#comment-16668906
]
ASF GitHub Bot commented on FLINK-10600:
pnowojski commented on issue #6924: [FL
pnowojski commented on issue #6924: [FLINK-10600] Provide End-to-end test cases
for modern Kafka connectors
URL: https://github.com/apache/flink/pull/6924#issuecomment-434354247
@yanghua it's not OK if we do not add `set -e`. The error would be still
there, but it would just be silently ig
[
https://issues.apache.org/jira/browse/FLINK-10638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-10638:
--
Assignee: Piotr Nowojski (was: Timo Walther)
> Invalid table scan resolution for tem
[
https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16668884#comment-16668884
]
ASF GitHub Bot commented on FLINK-10600:
yanghua commented on issue #6924: [FLIN
yanghua commented on issue #6924: [FLINK-10600] Provide End-to-end test cases
for modern Kafka connectors
URL: https://github.com/apache/flink/pull/6924#issuecomment-434348494
@pnowojski You can check the [old Travis
log](https://api.travis-ci.org/v3/job/448260257/log.txt). Just search :
[
https://issues.apache.org/jira/browse/FLINK-10617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16668873#comment-16668873
]
Elias Levy edited comment on FLINK-10617 at 10/30/18 3:28 PM:
[
https://issues.apache.org/jira/browse/FLINK-10617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Elias Levy updated FLINK-10617:
---
Affects Version/s: 1.6.2
> Restoring job fails because of slot allocation timeout
>
[
https://issues.apache.org/jira/browse/FLINK-10617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Elias Levy updated FLINK-10617:
---
Priority: Critical (was: Major)
> Restoring job fails because of slot allocation timeout
>
[
https://issues.apache.org/jira/browse/FLINK-10617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16668873#comment-16668873
]
Elias Levy commented on FLINK-10617:
I've retested with 1.6.2 and have confirmed the
[
https://issues.apache.org/jira/browse/FLINK-10686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16668863#comment-16668863
]
Timo Walther commented on FLINK-10686:
--
[~phoenixjiangnan] I think we cannot fix th
[
https://issues.apache.org/jira/browse/FLINK-10726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16668861#comment-16668861
]
ASF GitHub Bot commented on FLINK-10726:
twalthr commented on issue #6964: [FLIN
twalthr commented on issue #6964: [FLINK-10726] [table] Include
flink-table-common in flink-table jar
URL: https://github.com/apache/flink/pull/6964#issuecomment-434343428
The build passed on my Travis. I will merge this shortly...
--
Nico Kruber created FLINK-10727:
---
Summary: Remove unnecessary synchronization in
SingleInputGate#requestPartitions()
Key: FLINK-10727
URL: https://issues.apache.org/jira/browse/FLINK-10727
Project: Flin
[
https://issues.apache.org/jira/browse/FLINK-7816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned FLINK-7816:
---
Assignee: Aljoscha Krettek
> Support Scala 2.12 closures and Java 8 lambdas in Closu
[
https://issues.apache.org/jira/browse/FLINK-10678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16668854#comment-16668854
]
Till Rohrmann commented on FLINK-10678:
---
I guess that every test which disables th
[
https://issues.apache.org/jira/browse/FLINK-10711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16668852#comment-16668852
]
Hequn Cheng commented on FLINK-10711:
-
Agree, `set -euo pipefail` is better.
> flin
[
https://issues.apache.org/jira/browse/FLINK-9552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber reassigned FLINK-9552:
--
Assignee: Nico Kruber (was: vinoyang)
> NPE in SpanningRecordSerializer during checkpoint wit
[
https://issues.apache.org/jira/browse/FLINK-8985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz updated FLINK-8985:
Description: We should add end-to-end test which verifies that all client
commands are work
[
https://issues.apache.org/jira/browse/FLINK-10368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16668837#comment-16668837
]
Dawid Wysakowicz commented on FLINK-10368:
--
I've tried to harden the test by:
*
[
https://issues.apache.org/jira/browse/FLINK-10368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz reassigned FLINK-10368:
Assignee: Dawid Wysakowicz
> 'Kerberized YARN on Docker test' instable
>
[
https://issues.apache.org/jira/browse/FLINK-10711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16668835#comment-16668835
]
Piotr Nowojski commented on FLINK-10711:
Yes, that's a good point. Probably {{se
[
https://issues.apache.org/jira/browse/FLINK-10368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10368:
---
Labels: pull-request-available test-stability (was: test-stability)
> 'Kerberized YARN on D
[
https://issues.apache.org/jira/browse/FLINK-10368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16668821#comment-16668821
]
ASF GitHub Bot commented on FLINK-10368:
dawidwys opened a new pull request #696
dawidwys opened a new pull request #6965: [FLINK-10368][e2e] Hardened
kerberized yarn e2e test
URL: https://github.com/apache/flink/pull/6965
Hardened the kerberized yarn e2e test, especially having in mind
environments poor in resources.
Changes:
* wait for whole bootstrap
[
https://issues.apache.org/jira/browse/FLINK-10711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16668796#comment-16668796
]
Hequn Cheng commented on FLINK-10711:
-
How about start scripts with `set -eo pipefai
[
https://issues.apache.org/jira/browse/FLINK-10714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-10714.
--
Resolution: Not A Problem
User code was not holding the checkpointing lock in the source.
> j
[
https://issues.apache.org/jira/browse/FLINK-10714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16668776#comment-16668776
]
Stefan Richter commented on FLINK-10714:
[~cmick] I had a look at your code and
[
https://issues.apache.org/jira/browse/FLINK-10669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16668774#comment-16668774
]
Dawid Wysakowicz commented on FLINK-10669:
--
I think you are right. Let's wait f
[
https://issues.apache.org/jira/browse/FLINK-10357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao reopened FLINK-10357:
--
> Streaming File Sink end-to-end test failed with mismatch
> -
[
https://issues.apache.org/jira/browse/FLINK-10357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao updated FLINK-10357:
-
Affects Version/s: 1.7.0
> Streaming File Sink end-to-end test failed with mismatch
> --
[
https://issues.apache.org/jira/browse/FLINK-10357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao closed FLINK-10357.
Resolution: Fixed
> Streaming File Sink end-to-end test failed with mismatch
> ---
[
https://issues.apache.org/jira/browse/FLINK-10357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao closed FLINK-10357.
Resolution: Fixed
1.7: fddc52de3d8ce5ecbbf012441cb71a7b75ba2595
> Streaming File Sink end-to-end test fai
[
https://issues.apache.org/jira/browse/FLINK-10357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao updated FLINK-10357:
-
Fix Version/s: (was: 1.6.3)
> Streaming File Sink end-to-end test failed with mismatch
> ---
[
https://issues.apache.org/jira/browse/FLINK-10357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16668760#comment-16668760
]
ASF GitHub Bot commented on FLINK-10357:
GJL closed pull request #6907: [FLINK-1
GJL closed pull request #6907: [FLINK-10357][tests] Improve StreamingFileSink
E2E test stability.
URL: https://github.com/apache/flink/pull/6907
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As
[
https://issues.apache.org/jira/browse/FLINK-10704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16668758#comment-16668758
]
Piotr Nowojski commented on FLINK-10704:
I'm not sure if we should catch only ca
[
https://issues.apache.org/jira/browse/FLINK-9635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16668753#comment-16668753
]
ASF GitHub Bot commented on FLINK-9635:
---
StefanRRichter commented on a change in pu
StefanRRichter commented on a change in pull request #6961: [FLINK-9635] Fix
scheduling for local recovery
URL: https://github.com/apache/flink/pull/6961#discussion_r229319663
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/SlotContext.java
##
[
https://issues.apache.org/jira/browse/FLINK-10605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16668745#comment-16668745
]
ASF GitHub Bot commented on FLINK-10605:
asfgit closed pull request #6881: [FLIN
[
https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16668746#comment-16668746
]
ASF GitHub Bot commented on FLINK-10600:
pnowojski commented on issue #6924: [FL
asfgit closed pull request #6881: [FLINK-10605] [core] Upgrade AvroSerializer
snapshot to implement new TypeSerializerSnapshot interface
URL: https://github.com/apache/flink/pull/6881
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed
pnowojski commented on issue #6924: [FLINK-10600] Provide End-to-end test cases
for modern Kafka connectors
URL: https://github.com/apache/flink/pull/6924#issuecomment-434311640
How do they fail? I would say they should be fixed and if errors are
expected, they should be handled.
tillrohrmann commented on a change in pull request #6961: [FLINK-9635] Fix
scheduling for local recovery
URL: https://github.com/apache/flink/pull/6961#discussion_r229310831
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/SlotContext.java
##
@
[
https://issues.apache.org/jira/browse/FLINK-9635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16668738#comment-16668738
]
ASF GitHub Bot commented on FLINK-9635:
---
tillrohrmann commented on a change in pull
[
https://issues.apache.org/jira/browse/FLINK-9635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16668739#comment-16668739
]
ASF GitHub Bot commented on FLINK-9635:
---
tillrohrmann commented on a change in pull
tillrohrmann commented on a change in pull request #6961: [FLINK-9635] Fix
scheduling for local recovery
URL: https://github.com/apache/flink/pull/6961#discussion_r22935
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/PreviousAllocationSche
[
https://issues.apache.org/jira/browse/FLINK-8995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-8995.
-
Resolution: Implemented
Merged in:
master: 0e9a249fb8
> Add a test operator with keyed state tha
[
https://issues.apache.org/jira/browse/FLINK-10726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16668712#comment-16668712
]
ASF GitHub Bot commented on FLINK-10726:
aljoscha commented on issue #6964: [FLI
aljoscha commented on issue #6964: [FLINK-10726] [table] Include
flink-table-common in flink-table jar
URL: https://github.com/apache/flink/pull/6964#issuecomment-434305749
Looks good, if it passes the tests!
This is an autom
[
https://issues.apache.org/jira/browse/FLINK-10726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16668705#comment-16668705
]
ASF GitHub Bot commented on FLINK-10726:
twalthr opened a new pull request #6964
[
https://issues.apache.org/jira/browse/FLINK-10726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10726:
---
Labels: pull-request-available (was: )
> Streaming SQL end-to-end test fails due to recent
twalthr opened a new pull request #6964: [FLINK-10726] [table] Include
flink-table-common in flink-table jar
URL: https://github.com/apache/flink/pull/6964
## What is the purpose of the change
`flink-table-common` is not included in the `flink-table` jar which leads to
failure in th
[
https://issues.apache.org/jira/browse/FLINK-8995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16668701#comment-16668701
]
ASF GitHub Bot commented on FLINK-8995:
---
asfgit closed pull request #6909: [FLINK-8
asfgit closed pull request #6909: [FLINK-8995][tests] Add keyed state that uses
custom stateful seriali…
URL: https://github.com/apache/flink/pull/6909
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenanc
[
https://issues.apache.org/jira/browse/FLINK-8995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16668699#comment-16668699
]
ASF GitHub Bot commented on FLINK-8995:
---
StefanRRichter commented on issue #6909: [
StefanRRichter commented on issue #6909: [FLINK-8995][tests] Add keyed state
that uses custom stateful seriali…
URL: https://github.com/apache/flink/pull/6909#issuecomment-434303358
@tzulitai Thanks for the review. Merging.
T
[
https://issues.apache.org/jira/browse/FLINK-10725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sina Madani updated FLINK-10725:
Affects Version/s: 2.0.0
1.8.0
1.7.0
> Support for J
[
https://issues.apache.org/jira/browse/FLINK-10725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sina Madani updated FLINK-10725:
Affects Version/s: (was: 1.6.2)
> Support for Java 11 (LTS)
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-9635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16668679#comment-16668679
]
ASF GitHub Bot commented on FLINK-9635:
---
StefanRRichter commented on a change in pu
StefanRRichter commented on a change in pull request #6961: [FLINK-9635] Fix
scheduling for local recovery
URL: https://github.com/apache/flink/pull/6961#discussion_r229298268
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/PreviousAllocationSc
[
https://issues.apache.org/jira/browse/FLINK-9635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16668678#comment-16668678
]
ASF GitHub Bot commented on FLINK-9635:
---
StefanRRichter commented on a change in pu
StefanRRichter commented on a change in pull request #6961: [FLINK-9635] Fix
scheduling for local recovery
URL: https://github.com/apache/flink/pull/6961#discussion_r229297355
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/SlotInfo.java
##
@@
[
https://issues.apache.org/jira/browse/FLINK-9635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16668676#comment-16668676
]
ASF GitHub Bot commented on FLINK-9635:
---
StefanRRichter commented on a change in pu
StefanRRichter commented on a change in pull request #6961: [FLINK-9635] Fix
scheduling for local recovery
URL: https://github.com/apache/flink/pull/6961#discussion_r229297185
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPool.java
#
[
https://issues.apache.org/jira/browse/FLINK-10726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-10726:
-
Affects Version/s: 1.7.0
> Streaming SQL end-to-end test fails due to recent flink-table-common
Timo Walther created FLINK-10726:
Summary: Streaming SQL end-to-end test fails due to recent
flink-table-common changes
Key: FLINK-10726
URL: https://issues.apache.org/jira/browse/FLINK-10726
Project:
[
https://issues.apache.org/jira/browse/FLINK-10725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz updated FLINK-10725:
-
Component/s: (was: Core)
Build System
> Support for Java 11 (LTS)
>
101 - 200 of 297 matches
Mail list logo
