[
https://issues.apache.org/jira/browse/FLINK-8985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-8985.
-
Resolution: Fixed
Fix Version/s: 1.7.0
Fixed in 1.8: 44f217555f6ca72d1aa38d8626c1673a76c12
[
https://issues.apache.org/jira/browse/FLINK-10807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiayi Liao updated FLINK-10807:
---
Description: subscribedPartitionsToStartOffsets in KafkaConsumerBase is
getting values from restored
Jiayi Liao created FLINK-10807:
--
Summary: KafkaConsumer still consume removed topic after changing
topics list
Key: FLINK-10807
URL: https://issues.apache.org/jira/browse/FLINK-10807
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-10790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1660#comment-1660
]
ASF GitHub Bot commented on FLINK-10790:
zhijiangW commented on issue #7037: [FL
zhijiangW commented on issue #7037: [FLINK-10790][network] Refactor
StreamPartitioner implementations into runtime module
URL: https://github.com/apache/flink/pull/7037#issuecomment-436525702
@pnowojski , there are some problems for this issue now. I will update the
codes later. Sorry for
[
https://issues.apache.org/jira/browse/FLINK-10384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-10384:
-
Comment: was deleted
(was: [~pnovi...@gmail.com] I think this issue could be closed.)
> Add Sinh math f
[
https://issues.apache.org/jira/browse/FLINK-10384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang closed FLINK-10384.
Resolution: Fixed
Fix Version/s: 1.7.0
> Add Sinh math function supported in Table API and SQL
> --
tzulitai commented on issue #7028: [FLINK-10789] New serializer snapshots after
1.6 should implement TypeSerializerSnapshot
URL: https://github.com/apache/flink/pull/7028#issuecomment-436501351
Thanks for the review @StefanRRichter!
Will proceed to merge this and also the 1.7 backport.
[
https://issues.apache.org/jira/browse/FLINK-10789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16677657#comment-16677657
]
ASF GitHub Bot commented on FLINK-10789:
tzulitai commented on issue #7028: [FLI
[
https://issues.apache.org/jira/browse/FLINK-10791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16677655#comment-16677655
]
ASF GitHub Bot commented on FLINK-10791:
yanghua opened a new pull request #7038
[
https://issues.apache.org/jira/browse/FLINK-10791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10791:
---
Labels: pull-request-available (was: )
> Provide end-to-end test for Kafka 0.11 connector
>
yanghua opened a new pull request #7038: [FLINK-10791] Provide end-to-end test
for Kafka 0.11 connector
URL: https://github.com/apache/flink/pull/7038
## What is the purpose of the change
*Provide end-to-end test for Kafka 0.11 connector*
## Brief change log
-
[
https://issues.apache.org/jira/browse/FLINK-10790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16677646#comment-16677646
]
ASF GitHub Bot commented on FLINK-10790:
zhijiangW commented on issue #7037: [FL
zhijiangW commented on issue #7037: [FLINK-10790][network] Refactor
StreamPartitioner implementations into runtime module
URL: https://github.com/apache/flink/pull/7037#issuecomment-436496303
@pnowojski , this is the preparation for unifying implementations in both
stream and batch modes.
[
https://issues.apache.org/jira/browse/FLINK-10790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10790:
---
Labels: pull-request-available (was: )
> Refactor all the StreamPartitioner implementations
[
https://issues.apache.org/jira/browse/FLINK-10790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16677643#comment-16677643
]
ASF GitHub Bot commented on FLINK-10790:
zhijiangW opened a new pull request #70
zhijiangW opened a new pull request #7037: [FLINK-10790][network] Refactor
StreamPartitioner implementations into runtime module
URL: https://github.com/apache/flink/pull/7037
## What is the purpose of the change
*Before refactoring `ChannelSelector` interface mentioned in
[FLINK-10
[
https://issues.apache.org/jira/browse/FLINK-10806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiayi Liao updated FLINK-10806:
---
Summary: Support multiple consuming offsets when discovering a new topic
(was: Add optional consumi
[
https://issues.apache.org/jira/browse/FLINK-10806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiayi Liao updated FLINK-10806:
---
Summary: Add optional consuming parameters when discovering a new topic
(was: Support consume from
Jiayi Liao created FLINK-10806:
--
Summary: Support consume from earliest offset with a new topic
Key: FLINK-10806
URL: https://issues.apache.org/jira/browse/FLINK-10806
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-10706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16677570#comment-16677570
]
Yadong Xie commented on FLINK-10706:
Hi [~fwollert], would you please assign this is
[
https://issues.apache.org/jira/browse/FLINK-9699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16677502#comment-16677502
]
ASF GitHub Bot commented on FLINK-9699:
---
zjffdu commented on issue #6236: [FLINK-96
zjffdu commented on issue #6236: [FLINK-9699] [table] Add api to replace
registered table
URL: https://github.com/apache/flink/pull/6236#issuecomment-436471468
Thanks @hequn8128 @yanghua `registerOrReplaceXXX` make sense for me. I will
update the PR.
--
[
https://issues.apache.org/jira/browse/FLINK-10802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16677495#comment-16677495
]
lining commented on FLINK-10802:
Hi [~till.rohrmann], now user see something need click
[
https://issues.apache.org/jira/browse/FLINK-10644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JIN SUN updated FLINK-10644:
Description:
Strugglers/outlier are tasks that run slower than most of the all tasks in a
Batch Job, this
[
https://issues.apache.org/jira/browse/FLINK-10644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JIN SUN updated FLINK-10644:
Description:
Strugglers/outlier are tasks that run slower than most of the all tasks in a
Batch Job, this
[
https://issues.apache.org/jira/browse/FLINK-10671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao closed FLINK-10671.
Resolution: Not A Problem
Please reopen if necessary.
> rest monitoring api Savepoint status call fails
[
https://issues.apache.org/jira/browse/FLINK-10356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16677127#comment-16677127
]
ASF GitHub Bot commented on FLINK-10356:
NicoK commented on issue #6705: [FLINK-
NicoK commented on issue #6705: [FLINK-10356][network] add sanity checks to
SpillingAdaptiveSpanningRecordDeserializer
URL: https://github.com/apache/flink/pull/6705#issuecomment-436356439
Thanks @zhijiangW and @pnowojski for the reviews. I have addressed the
comments and committed some ch
[
https://issues.apache.org/jira/browse/FLINK-10768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16677099#comment-16677099
]
ASF GitHub Bot commented on FLINK-10768:
bowenli86 commented on issue #7011: [FL
bowenli86 commented on issue #7011: [FLINK-10768][Table & SQL] Move external
catalog related code from TableEnvironment to CatalogManager
URL: https://github.com/apache/flink/pull/7011#issuecomment-436350350
holding on this PR as there are some related discussion going on at[ the
design
d
[
https://issues.apache.org/jira/browse/FLINK-10699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-10699:
-
Summary: Create FlinkHmsCatalog for persistent Flink meta objects using
Hive metastore as a registry (w
[
https://issues.apache.org/jira/browse/FLINK-10531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas updated FLINK-10531:
---
Fix Version/s: 1.7.0
> State TTL RocksDb backend end-to-end test failed on Travis
>
[
https://issues.apache.org/jira/browse/FLINK-10531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16677023#comment-16677023
]
ASF GitHub Bot commented on FLINK-10531:
kl0u commented on issue #7036: [FLINK-1
kl0u commented on issue #7036: [FLINK-10531][e2e] Fix unstable TTL end-to-end
test.
URL: https://github.com/apache/flink/pull/7036#issuecomment-436331588
R @azagrebin
This is an automated message from the Apache Git Service.
[
https://issues.apache.org/jira/browse/FLINK-10531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16677018#comment-16677018
]
ASF GitHub Bot commented on FLINK-10531:
kl0u opened a new pull request #7036: [
[
https://issues.apache.org/jira/browse/FLINK-10531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10531:
---
Labels: pull-request-available test-stability (was: test-stability)
> State TTL RocksDb bac
kl0u opened a new pull request #7036: [FLINK-10531][e2e] Fix unstable TTL
end-to-end test.
URL: https://github.com/apache/flink/pull/7036
As describe on the JIRA, the problem is that the clock on the machine on
Travis seems to have jumped backwards.
This resulted in a mismatch betwe
[
https://issues.apache.org/jira/browse/FLINK-10797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16677010#comment-16677010
]
ASF GitHub Bot commented on FLINK-10797:
xndai closed pull request #7025: [FLINK
xndai closed pull request #7025: [FLINK-10797] "IntelliJ Setup" link is broken
in README.md
URL: https://github.com/apache/flink/pull/7025
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 this i
[
https://issues.apache.org/jira/browse/FLINK-10796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16676991#comment-16676991
]
Bowen Li commented on FLINK-10796:
--
[~xiaow...@gmail.com] That's right. I've added the
[
https://issues.apache.org/jira/browse/FLINK-10796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-10796:
-
Description:
CatalogManager has a default catalog (as FlinkInMemoryCatalog), which will be
selected whe
[
https://issues.apache.org/jira/browse/FLINK-10789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16676988#comment-16676988
]
ASF GitHub Bot commented on FLINK-10789:
StefanRRichter commented on a change in
StefanRRichter commented on a change in pull request #7028: [FLINK-10789] New
serializer snapshots after 1.6 should implement TypeSerializerSnapshot
URL: https://github.com/apache/flink/pull/7028#discussion_r231202779
##
File path:
flink-scala/src/main/java/org/apache/flink/api/sca
[
https://issues.apache.org/jira/browse/FLINK-10796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-10796:
-
Description:
CatalogManager has a default catalog, which will be selected when a catalog
name isn’t giv
asfgit closed pull request #5863: [FLINK-8985][e2etest] initial support for
End-to-end CLI test, excluding YARN test
URL: https://github.com/apache/flink/pull/5863
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake
[
https://issues.apache.org/jira/browse/FLINK-8985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16676976#comment-16676976
]
ASF GitHub Bot commented on FLINK-8985:
---
asfgit closed pull request #5863: [FLINK-8
[
https://issues.apache.org/jira/browse/FLINK-10463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16676968#comment-16676968
]
Xingcan Cui commented on FLINK-10463:
-
[~twalthr], sure. I'll cherry-pick the commit
[
https://issues.apache.org/jira/browse/FLINK-10463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingcan Cui updated FLINK-10463:
Fix Version/s: 1.7.1
1.6.3
> Null literal cannot be properly parsed in Java Tab
[
https://issues.apache.org/jira/browse/FLINK-10720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-10720.
--
Resolution: Implemented
Merged in:
master: 660bb687c1
release-1.7: 380df0559b
> Add stress de
[
https://issues.apache.org/jira/browse/FLINK-10531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16676957#comment-16676957
]
Kostas Kloudas commented on FLINK-10531:
It is a test instability.
The way the
[
https://issues.apache.org/jira/browse/FLINK-10463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16676955#comment-16676955
]
Timo Walther commented on FLINK-10463:
--
[~xccui] can you also cherry-pick bug fixes
[
https://issues.apache.org/jira/browse/FLINK-10531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas reassigned FLINK-10531:
--
Assignee: Kostas Kloudas (was: Renjie Liu)
> State TTL RocksDb backend end-to-end te
[
https://issues.apache.org/jira/browse/FLINK-10720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16676948#comment-16676948
]
ASF GitHub Bot commented on FLINK-10720:
asfgit closed pull request #6994: [FLIN
asfgit closed pull request #6994: [FLINK-10720][tests] Add deployment
end-to-end stress test with many …
URL: https://github.com/apache/flink/pull/6994
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-10720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16676943#comment-16676943
]
ASF GitHub Bot commented on FLINK-10720:
StefanRRichter commented on issue #6994
StefanRRichter commented on issue #6994: [FLINK-10720][tests] Add deployment
end-to-end stress test with many …
URL: https://github.com/apache/flink/pull/6994#issuecomment-436309544
Thanks @tillrohrmann! Merging.
This is an a
[
https://issues.apache.org/jira/browse/FLINK-10805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10805:
---
Labels: pull-request-available test-stability (was: test-stability)
> test_confluent_schema
tillrohrmann opened a new pull request #7035: [BP-1.7][FLINK-10805] Fix failing
end-to-end tests
URL: https://github.com/apache/flink/pull/7035
Backport of #7034 for `release-1.7`.
This is an automated message from the Apache
tillrohrmann opened a new pull request #7034: [FLINK-10805] Fix failing
end-to-end tests
URL: https://github.com/apache/flink/pull/7034
## What is the purpose of the change
Fix test_confluent_schema_registry.sh and test_sql_client.sh end-to-end
tests which failed
because of missi
[
https://issues.apache.org/jira/browse/FLINK-10805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16676937#comment-16676937
]
ASF GitHub Bot commented on FLINK-10805:
tillrohrmann opened a new pull request
[
https://issues.apache.org/jira/browse/FLINK-10771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16676916#comment-16676916
]
vinoyang commented on FLINK-10771:
--
Yes, In AbstractYarnClusterDescriptor, we can expli
[
https://issues.apache.org/jira/browse/FLINK-8985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16676906#comment-16676906
]
ASF GitHub Bot commented on FLINK-8985:
---
twalthr commented on issue #5863: [FLINK-8
[
https://issues.apache.org/jira/browse/FLINK-8985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-8985:
--
Labels: pull-request-available (was: )
> End-to-end test: CLI
>
>
>
twalthr commented on issue #5863: [FLINK-8985][e2etest] initial support for
End-to-end CLI test, excluding YARN test
URL: https://github.com/apache/flink/pull/5863#issuecomment-436296096
Thanks for the PR @walterddr. I think the test looks good to merge. I will
add some additional safety c
[
https://issues.apache.org/jira/browse/FLINK-10463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingcan Cui resolved FLINK-10463.
-
Resolution: Fixed
Fixed in 1.8.0 5a4e5e9dcaa83368862d27bd80429235c02ed66e
> Null literal cannot
[
https://issues.apache.org/jira/browse/FLINK-10463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingcan Cui updated FLINK-10463:
Fix Version/s: 1.8.0
> Null literal cannot be properly parsed in Java Table API function call
> --
[
https://issues.apache.org/jira/browse/FLINK-10463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16676893#comment-16676893
]
ASF GitHub Bot commented on FLINK-10463:
asfgit closed pull request #6888: [FLIN
asfgit closed pull request #6888: [FLINK-10463][table] Null literal cannot be
properly parsed in Java Table API function call
URL: https://github.com/apache/flink/pull/6888
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
[
https://issues.apache.org/jira/browse/FLINK-10805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-10805:
--
Description:
The end-to-end test {{test_confluent_schema_registry.sh}} and
{{test_sql_client.
[
https://issues.apache.org/jira/browse/FLINK-10771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16676883#comment-16676883
]
Till Rohrmann commented on FLINK-10771:
---
Or better to set a value in the {{Configu
[
https://issues.apache.org/jira/browse/FLINK-9699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16676878#comment-16676878
]
ASF GitHub Bot commented on FLINK-9699:
---
yanghua commented on issue #6236: [FLINK-9
yanghua commented on issue #6236: [FLINK-9699] [table] Add api to replace
registered table
URL: https://github.com/apache/flink/pull/6236#issuecomment-436288232
@hequn8128 I agree with you. Actually, I have given a similar suggestion
about `CREATE VIEW` in SQL client. See
[FLINK-10420](ht
[
https://issues.apache.org/jira/browse/FLINK-10384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16676875#comment-16676875
]
vinoyang commented on FLINK-10384:
--
[~pnovi...@gmail.com] I think this issue could be c
[
https://issues.apache.org/jira/browse/FLINK-10771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16676866#comment-16676866
]
vinoyang commented on FLINK-10771:
--
OK, since it may be used, why don't we refactor it
Till Rohrmann created FLINK-10805:
-
Summary: test_confluent_schema_registry.sh and test_sql_client.sh
end-to-end test broken
Key: FLINK-10805
URL: https://issues.apache.org/jira/browse/FLINK-10805
Pro
[
https://issues.apache.org/jira/browse/FLINK-10802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16676850#comment-16676850
]
Till Rohrmann commented on FLINK-10802:
---
Hi [~lining], I think this could be usefu
[
https://issues.apache.org/jira/browse/FLINK-10463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16676846#comment-16676846
]
ASF GitHub Bot commented on FLINK-10463:
hequn8128 commented on issue #6888: [FL
hequn8128 commented on issue #6888: [FLINK-10463][table] Null literal cannot be
properly parsed in Java Table API function call
URL: https://github.com/apache/flink/pull/6888#issuecomment-436276465
Thank you all for the review and suggestions!
--
[
https://issues.apache.org/jira/browse/FLINK-10771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16676841#comment-16676841
]
Till Rohrmann commented on FLINK-10771:
---
But from the implementation of {{FileJobG
[
https://issues.apache.org/jira/browse/FLINK-9699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16676842#comment-16676842
]
ASF GitHub Bot commented on FLINK-9699:
---
hequn8128 commented on issue #6236: [FLINK
hequn8128 commented on issue #6236: [FLINK-9699] [table] Add api to replace
registered table
URL: https://github.com/apache/flink/pull/6236#issuecomment-436275448
@zjffdu Thanks for the PR. I think this feature is very useful. I haven't
taken a deep look at the code. Considering the api, h
shaoxuan-wang commented on issue #7025: [FLINK-10797] "IntelliJ Setup" link is
broken in README.md
URL: https://github.com/apache/flink/pull/7025#issuecomment-436263199
> @shaoxuan-wang regardless the duplication of this pr(#7025 ) and #7024 I'd
like to point out two concerns on this threa
[
https://issues.apache.org/jira/browse/FLINK-10797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16676792#comment-16676792
]
ASF GitHub Bot commented on FLINK-10797:
shaoxuan-wang commented on issue #7025:
[
https://issues.apache.org/jira/browse/FLINK-10795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16676791#comment-16676791
]
Hequn Cheng commented on FLINK-10795:
-
Hi, I had looked into this issue. I think it
[
https://issues.apache.org/jira/browse/FLINK-10419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10419:
---
Labels: pull-request-available (was: )
> ClassNotFoundException while deserializing user ex
[
https://issues.apache.org/jira/browse/FLINK-10419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16676768#comment-16676768
]
ASF GitHub Bot commented on FLINK-10419:
NicoK opened a new pull request #7033:
NicoK opened a new pull request #7033: [FLINK-10419][checkpoint] fix
ClassNotFoundException while deserializing user exceptions
URL: https://github.com/apache/flink/pull/7033
## What is the purpose of the change
`DeclineCheckpoint` tries to make sure that it does wrap any exception w
Nico Kruber created FLINK-10804:
---
Summary: Transfer suppressed exceptions with SerializedThrowable
Key: FLINK-10804
URL: https://issues.apache.org/jira/browse/FLINK-10804
Project: Flink
Issue T
[
https://issues.apache.org/jira/browse/FLINK-10797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16676750#comment-16676750
]
ASF GitHub Bot commented on FLINK-10797:
TisonKun edited a comment on issue #702
TisonKun edited a comment on issue #7025: [FLINK-10797] "IntelliJ Setup" link
is broken in README.md
URL: https://github.com/apache/flink/pull/7025#issuecomment-436249401
@shaoxuan-wang regardless the duplication of this pr(#7025 ) and #7024 I'd
like to point out two concerns on this threa
TisonKun commented on issue #7025: [FLINK-10797] "IntelliJ Setup" link is
broken in README.md
URL: https://github.com/apache/flink/pull/7025#issuecomment-436249401
@shaoxuan-wang regardless the duplication of this pr(#7025 ) and #7024 I'd
like to point out two concerns on this thread.
[
https://issues.apache.org/jira/browse/FLINK-10797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16676747#comment-16676747
]
ASF GitHub Bot commented on FLINK-10797:
TisonKun commented on issue #7025: [FLI
[
https://issues.apache.org/jira/browse/FLINK-10353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16676695#comment-16676695
]
ASF GitHub Bot commented on FLINK-10353:
StefanRRichter commented on issue #7010
StefanRRichter commented on issue #7010: [FLINK-10353][kafka] Support change of
transactional semantics in Kaf…
URL: https://github.com/apache/flink/pull/7010#issuecomment-436235901
Addressed the comments. Please have another look.
--
[
https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16676692#comment-16676692
]
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-436235491
@shaoxuan-wang Can you share your error log with us? The test cases related
to kafka connector are not very stable
shaoxuan-wang 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-436234220
@pnowojski @yanghuaI got this test failure when I rebase the flink
master to my own repository which is
[
https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16676690#comment-16676690
]
ASF GitHub Bot commented on FLINK-10600:
shaoxuan-wang commented on issue #6924:
[
https://issues.apache.org/jira/browse/FLINK-10801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-10801:
-
Description:
It usually reports :
{code:java}
FAIL SQL Client Elasticsearch Upsert: Output hash mismatc
1 - 100 of 224 matches
Mail list logo