[
https://issues.apache.org/jira/browse/FLINK-10820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16684825#comment-16684825
]
ASF GitHub Bot commented on FLINK-10820:
zhijiangW commented on a change in pull
zhijiangW commented on a change in pull request #7051: [FLINK-10820][network]
Simplify the RebalancePartitioner implementation
URL: https://github.com/apache/flink/pull/7051#discussion_r232926075
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/pa
[
https://issues.apache.org/jira/browse/FLINK-10818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16684814#comment-16684814
]
ambition edited comment on FLINK-10818 at 11/13/18 7:37 AM:
[
https://issues.apache.org/jira/browse/FLINK-10818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16684814#comment-16684814
]
ambition edited comment on FLINK-10818 at 11/13/18 7:36 AM:
[
https://issues.apache.org/jira/browse/FLINK-10818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16684814#comment-16684814
]
ambition commented on FLINK-10818:
--
[^jobmanager.log][^taskmanager.log]
> RestartStrat
[
https://issues.apache.org/jira/browse/FLINK-10818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ambition updated FLINK-10818:
-
Attachment: jobmanager.log
> RestartStrategies.fixedDelayRestart Occur NoResourceAvailableException: No
[
https://issues.apache.org/jira/browse/FLINK-10818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ambition updated FLINK-10818:
-
Attachment: taskmanager.log
> RestartStrategies.fixedDelayRestart Occur NoResourceAvailableException: N
[
https://issues.apache.org/jira/browse/FLINK-10857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Truong Duc Kien updated FLINK-10857:
Description:
When registering both JMX and Prometheus metrics reporter, the Prometheus
re
Truong Duc Kien created FLINK-10857:
---
Summary: Conflict between JMX and Prometheus Metrics reporter
Key: FLINK-10857
URL: https://issues.apache.org/jira/browse/FLINK-10857
Project: Flink
Is
[
https://issues.apache.org/jira/browse/FLINK-10674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16684786#comment-16684786
]
ASF GitHub Bot commented on FLINK-10674:
wenhuitang opened a new pull request #7
[
https://issues.apache.org/jira/browse/FLINK-10674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16684785#comment-16684785
]
ASF GitHub Bot commented on FLINK-10674:
wenhuitang closed pull request #7076: [
wenhuitang opened a new pull request #7076: [FLINK-10674] [table] Fix
DistinctAccumulator.remove lead to NPE.
URL: https://github.com/apache/flink/pull/7076
## What is the purpose of the change
This pull request fixes the problem reported by FLINK-10674
DistinctAccumulator.remove le
wenhuitang closed pull request #7076: [FLINK-10674] [table] Fix
DistinctAccumulator.remove lead to NPE.
URL: https://github.com/apache/flink/pull/7076
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
[
https://issues.apache.org/jira/browse/FLINK-10855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-10855:
Assignee: vinoyang
> CheckpointCoordinator does not delete checkpoint directory of late/failed
>
[
https://issues.apache.org/jira/browse/FLINK-10851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16684717#comment-16684717
]
frank wang commented on FLINK-10851:
OK，it can work，thx
> sqlUpdate support complex
[
https://issues.apache.org/jira/browse/FLINK-10851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
frank wang closed FLINK-10851.
--
Resolution: Resolved
> sqlUpdate support complex insert grammar
>
[
https://issues.apache.org/jira/browse/FLINK-9555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16684704#comment-16684704
]
sunjincheng commented on FLINK-9555:
Thanks for report this issue Jeff Zhang ！
+1 to
[
https://issues.apache.org/jira/browse/FLINK-10845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16684693#comment-16684693
]
ASF GitHub Bot commented on FLINK-10845:
hequn8128 commented on a change in pull
hequn8128 commented on a change in pull request #7079: [FLINK-10845][table]
Support multiple different DISTINCT aggregates for batch
URL: https://github.com/apache/flink/pull/7079#discussion_r232887066
##
File path:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/
[
https://issues.apache.org/jira/browse/FLINK-10845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16684675#comment-16684675
]
ASF GitHub Bot commented on FLINK-10845:
hequn8128 commented on a change in pull
[
https://issues.apache.org/jira/browse/FLINK-10845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16684676#comment-16684676
]
ASF GitHub Bot commented on FLINK-10845:
hequn8128 commented on a change in pull
hequn8128 commented on a change in pull request #7079: [FLINK-10845][table]
Support multiple different DISTINCT aggregates for batch
URL: https://github.com/apache/flink/pull/7079#discussion_r232887066
##
File path:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/
hequn8128 commented on a change in pull request #7079: [FLINK-10845][table]
Support multiple different DISTINCT aggregates for batch
URL: https://github.com/apache/flink/pull/7079#discussion_r232887060
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/
maqingxiang opened a new pull request #7083: [hotfix][flink-runtime] modify
maxAttempts when find a unique file name for the spilling channel
URL: https://github.com/apache/flink/pull/7083
This is an automated message from t
[
https://issues.apache.org/jira/browse/FLINK-10766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16684644#comment-16684644
]
ASF GitHub Bot commented on FLINK-10766:
wuchong closed pull request #134: [FLIN
[
https://issues.apache.org/jira/browse/FLINK-10753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16684142#comment-16684142
]
ASF GitHub Bot commented on FLINK-10753:
StefanRRichter commented on issue #7064
[
https://issues.apache.org/jira/browse/FLINK-10753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-10753.
--
Resolution: Fixed
Fix Version/s: 1.6.3
1.5.6
Merged in:
master: dc8e
[
https://issues.apache.org/jira/browse/FLINK-10753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16684147#comment-16684147
]
ASF GitHub Bot commented on FLINK-10753:
asfgit closed pull request #7064: [FLIN
asfgit closed pull request #7064: [FLINK-10753] Improve propagation and logging
of snapshot exceptions
URL: https://github.com/apache/flink/pull/7064
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:
[
https://issues.apache.org/jira/browse/FLINK-10809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16684129#comment-16684129
]
ASF GitHub Bot commented on FLINK-10809:
asfgit closed pull request #7048: [FLIN
StefanRRichter commented on issue #7064: [FLINK-10753] Improve propagation and
logging of snapshot exceptions
URL: https://github.com/apache/flink/pull/7064#issuecomment-437965713
Thanks @tillrohrmann! Merging.
This is an aut
[
https://issues.apache.org/jira/browse/FLINK-10809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-10809.
--
Resolution: Fixed
Fix Version/s: 1.7.0
1.6.3
Merged in:
master: bf76
[
https://issues.apache.org/jira/browse/FLINK-10419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16684130#comment-16684130
]
ASF GitHub Bot commented on FLINK-10419:
dawidwys opened a new pull request #708
dawidwys opened a new pull request #7082: [FLINK-10419] Using DeclineCheckpoint
message class when invoking RPC declineCheckpoint
URL: https://github.com/apache/flink/pull/7082
## What is the purpose of the change
Invoking `declineCheckpoint` RPC endpoint with `DeclineCheckpoint` mes
asfgit closed pull request #7048: [FLINK-10809][state] Include keyed state that
is not from head operat…
URL: https://github.com/apache/flink/pull/7048
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-10809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16684125#comment-16684125
]
ASF GitHub Bot commented on FLINK-10809:
StefanRRichter commented on issue #7048
StefanRRichter commented on issue #7048: [FLINK-10809][state] Include keyed
state that is not from head operat…
URL: https://github.com/apache/flink/pull/7048#issuecomment-437961859
Thanks for the review @tzulitai! Merging.
T
[
https://issues.apache.org/jira/browse/FLINK-10809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16684123#comment-16684123
]
ASF GitHub Bot commented on FLINK-10809:
StefanRRichter commented on a change in
StefanRRichter commented on a change in pull request #7048:
[FLINK-10809][state] Include keyed state that is not from head operat…
URL: https://github.com/apache/flink/pull/7048#discussion_r232744683
##
File path:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/da
[
https://issues.apache.org/jira/browse/FLINK-5490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16684113#comment-16684113
]
ASF GitHub Bot commented on FLINK-5490:
---
bmeriaux commented on issue #3977: [FLINK-
[
https://issues.apache.org/jira/browse/FLINK-5490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-5490:
--
Labels: pull-request-available (was: )
> ContextEnvironment.getExecutionPlan() clears Sinks
>
bmeriaux commented on issue #3977: [FLINK-5490] Not allowing sinks to be
cleared when getting the execut…
URL: https://github.com/apache/flink/pull/3977#issuecomment-437960610
hi @deepakmarathe,
do you have time to add the requested test ?
If not, i can do it, because I spend some tim
[
https://issues.apache.org/jira/browse/FLINK-10827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-10827.
--
Resolution: Fixed
Fix Version/s: 1.6.3
1.5.6
Merged in:
master: 2db5
[
https://issues.apache.org/jira/browse/FLINK-10839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-10839.
--
Resolution: Fixed
Fix Version/s: 1.5.6
Merged in:
master: c4d366c9ab
release-1.7: 19c34
[
https://issues.apache.org/jira/browse/FLINK-10827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16684071#comment-16684071
]
ASF GitHub Bot commented on FLINK-10827:
asfgit closed pull request #7061: [FLIN
asfgit closed pull request #7061: [FLINK-10827][tests] Add test for duplicate()
to SerializerTestBase
URL: https://github.com/apache/flink/pull/7061
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:
[
https://issues.apache.org/jira/browse/FLINK-10827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16684007#comment-16684007
]
ASF GitHub Bot commented on FLINK-10827:
StefanRRichter commented on issue #7061
StefanRRichter commented on issue #7061: [FLINK-10827][tests] Add test for
duplicate() to SerializerTestBase
URL: https://github.com/apache/flink/pull/7061#issuecomment-437937240
Thanks @tillrohrmann! Merging.
This is an auto
Till Rohrmann created FLINK-10856:
-
Summary: Harden resume from externalized checkpoint E2E test
Key: FLINK-10856
URL: https://issues.apache.org/jira/browse/FLINK-10856
Project: Flink
Issue T
Till Rohrmann created FLINK-10855:
-
Summary: CheckpointCoordinator does not delete checkpoint
directory of late/failed checkpoints
Key: FLINK-10855
URL: https://issues.apache.org/jira/browse/FLINK-10855
[
https://issues.apache.org/jira/browse/FLINK-10624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16683992#comment-16683992
]
ASF GitHub Bot commented on FLINK-10624:
yanghua commented on issue #6927: [FLIN
yanghua commented on issue #6927: [FLINK-10624] Extend SQL client end-to-end to
test new KafkaTableSink
URL: https://github.com/apache/flink/pull/6927#issuecomment-437933478
@pnowojski I saw one step of this test case is `echo "Executing SQL: Match
recognize -> Elasticsearch"` which contai
[
https://issues.apache.org/jira/browse/FLINK-10853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16683965#comment-16683965
]
ASF GitHub Bot commented on FLINK-10853:
yanghua commented on issue #7081: [FLIN
yanghua commented on issue #7081: [FLINK-10853] Provide end-to-end test for
Kafka 0.9 connector
URL: https://github.com/apache/flink/pull/7081#issuecomment-437928739
cc @pnowojski
This is an automated message from the Apache
[
https://issues.apache.org/jira/browse/FLINK-10624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16683963#comment-16683963
]
ASF GitHub Bot commented on FLINK-10624:
yanghua commented on issue #6927: [FLIN
yanghua commented on issue #6927: [FLINK-10624] Extend SQL client end-to-end to
test new KafkaTableSink
URL: https://github.com/apache/flink/pull/6927#issuecomment-437928244
@pnowojski I agree with you. Indeed, we can separate it. And splitting seems
to be mostly targeted at shell scripts.
[
https://issues.apache.org/jira/browse/FLINK-10853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10853:
---
Labels: pull-request-available (was: )
> Provide end-to-end test for Kafka 0.9 connector
>
yanghua opened a new pull request #7081: [FLINK-10853] Provide end-to-end test
for Kafka 0.9 connector
URL: https://github.com/apache/flink/pull/7081
## What is the purpose of the change
*This pull request provides end-to-end test for Kafka 0.9 connector*
## Brief change log
[
https://issues.apache.org/jira/browse/FLINK-10624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16683948#comment-16683948
]
ASF GitHub Bot commented on FLINK-10624:
pnowojski commented on a change in pull
pnowojski commented on a change in pull request #6927: [FLINK-10624] Extend SQL
client end-to-end to test new KafkaTableSink
URL: https://github.com/apache/flink/pull/6927#discussion_r232704128
##
File path: flink-end-to-end-tests/flink-sql-client-test-kafka-0.10/pom.xml
##
[
https://issues.apache.org/jira/browse/FLINK-9311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16683937#comment-16683937
]
ASF GitHub Bot commented on FLINK-9311:
---
nielsbasjes commented on a change in pull
[
https://issues.apache.org/jira/browse/FLINK-10624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16683944#comment-16683944
]
ASF GitHub Bot commented on FLINK-10624:
pnowojski commented on a change in pull
pnowojski commented on a change in pull request #6927: [FLINK-10624] Extend SQL
client end-to-end to test new KafkaTableSink
URL: https://github.com/apache/flink/pull/6927#discussion_r232702108
##
File path: flink-end-to-end-tests/flink-sql-client-test-kafka-0.10/pom.xml
##
nielsbasjes commented on issue #6594: [FLINK-9311] [pubsub] Added PubSub source
connector with support for checkpointing (ATLEAST_ONCE)
URL: https://github.com/apache/flink/pull/6594#issuecomment-437922403
From the review comments a few points remain open for me:
Both are about the way t
[
https://issues.apache.org/jira/browse/FLINK-9311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16683940#comment-16683940
]
ASF GitHub Bot commented on FLINK-9311:
---
nielsbasjes commented on issue #6594: [FLI
nielsbasjes commented on a change in pull request #6594: [FLINK-9311] [pubsub]
Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)
URL: https://github.com/apache/flink/pull/6594#discussion_r232700234
##
File path:
flink-connectors/flink-connector-pubsub/src/
[
https://issues.apache.org/jira/browse/FLINK-9311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16683934#comment-16683934
]
ASF GitHub Bot commented on FLINK-9311:
---
nielsbasjes commented on a change in pull
nielsbasjes commented on a change in pull request #6594: [FLINK-9311] [pubsub]
Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)
URL: https://github.com/apache/flink/pull/6594#discussion_r232699534
##
File path:
flink-connectors/flink-connector-pubsub/src/
[
https://issues.apache.org/jira/browse/FLINK-9311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16683926#comment-16683926
]
ASF GitHub Bot commented on FLINK-9311:
---
nielsbasjes commented on a change in pull
nielsbasjes commented on a change in pull request #6594: [FLINK-9311] [pubsub]
Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)
URL: https://github.com/apache/flink/pull/6594#discussion_r232697684
##
File path:
flink-connectors/flink-connector-pubsub/src/
[
https://issues.apache.org/jira/browse/FLINK-10851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16683913#comment-16683913
]
Hequn Cheng commented on FLINK-10851:
-
Hi, you can take a look at the {{testStreamSQ
[
https://issues.apache.org/jira/browse/FLINK-6083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16683912#comment-16683912
]
Barisa commented on FLINK-6083:
---
Hi Andrej. Are you able to expose information on the task
[
https://issues.apache.org/jira/browse/FLINK-9311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16683894#comment-16683894
]
ASF GitHub Bot commented on FLINK-9311:
---
nielsbasjes commented on a change in pull
[
https://issues.apache.org/jira/browse/FLINK-9311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16683906#comment-16683906
]
ASF GitHub Bot commented on FLINK-9311:
---
nielsbasjes commented on a change in pull
nielsbasjes commented on a change in pull request #6594: [FLINK-9311] [pubsub]
Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)
URL: https://github.com/apache/flink/pull/6594#discussion_r232690036
##
File path:
flink-connectors/flink-connector-pubsub/src/
nielsbasjes commented on a change in pull request #6594: [FLINK-9311] [pubsub]
Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)
URL: https://github.com/apache/flink/pull/6594#discussion_r232687817
##
File path:
flink-connectors/flink-connector-pubsub/src/
[
https://issues.apache.org/jira/browse/FLINK-9311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16683883#comment-16683883
]
ASF GitHub Bot commented on FLINK-9311:
---
nielsbasjes commented on a change in pull
nielsbasjes commented on a change in pull request #6594: [FLINK-9311] [pubsub]
Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)
URL: https://github.com/apache/flink/pull/6594#discussion_r232626013
##
File path: flink-examples/flink-examples-streaming/pom.x
[
https://issues.apache.org/jira/browse/FLINK-9311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16683880#comment-16683880
]
ASF GitHub Bot commented on FLINK-9311:
---
nielsbasjes commented on a change in pull
nielsbasjes commented on a change in pull request #6594: [FLINK-9311] [pubsub]
Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)
URL: https://github.com/apache/flink/pull/6594#discussion_r232681463
##
File path:
flink-connectors/flink-connector-pubsub/src/
[
https://issues.apache.org/jira/browse/FLINK-10851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16683800#comment-16683800
]
frank wang commented on FLINK-10851:
i don't think so
tableEnv.sqlUpdate("insert in
[
https://issues.apache.org/jira/browse/FLINK-10851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16683743#comment-16683743
]
Hequn Cheng edited comment on FLINK-10851 at 11/12/18 12:51 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-9311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16683747#comment-16683747
]
ASF GitHub Bot commented on FLINK-9311:
---
nielsbasjes commented on issue #6594: [FLI
nielsbasjes commented on issue #6594: [FLINK-9311] [pubsub] Added PubSub source
connector with support for checkpointing (ATLEAST_ONCE)
URL: https://github.com/apache/flink/pull/6594#issuecomment-437867011
I have fixed a subset of the review comments and rebased against the current
master.
[
https://issues.apache.org/jira/browse/FLINK-10851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16683743#comment-16683743
]
Hequn Cheng commented on FLINK-10851:
-
[~frank wang] Hi, thanks for creating this ji
[
https://issues.apache.org/jira/browse/FLINK-9311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16683699#comment-16683699
]
ASF GitHub Bot commented on FLINK-9311:
---
nielsbasjes commented on a change in pull
[
https://issues.apache.org/jira/browse/FLINK-9311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16683713#comment-16683713
]
ASF GitHub Bot commented on FLINK-9311:
---
nielsbasjes commented on a change in pull
vinoyang created FLINK-10854:
Summary: Provide end-to-end test for Kafka 0.8 connector
Key: FLINK-10854
URL: https://issues.apache.org/jira/browse/FLINK-10854
Project: Flink
Issue Type: Test
vinoyang created FLINK-10853:
Summary: Provide end-to-end test for Kafka 0.9 connector
Key: FLINK-10853
URL: https://issues.apache.org/jira/browse/FLINK-10853
Project: Flink
Issue Type: Test
[
https://issues.apache.org/jira/browse/FLINK-10821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-10821.
---
Resolution: Fixed
Fix Version/s: 1.6.3
1.5.6
Fixed via
master:
ht
[
https://issues.apache.org/jira/browse/FLINK-9311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16683702#comment-16683702
]
ASF GitHub Bot commented on FLINK-9311:
---
nielsbasjes commented on a change in pull
[
https://issues.apache.org/jira/browse/FLINK-10809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16683717#comment-16683717
]
ASF GitHub Bot commented on FLINK-10809:
tzulitai commented on issue #7048: [FLI
tzulitai commented on issue #7048: [FLINK-10809][state] Include keyed state
that is not from head operat…
URL: https://github.com/apache/flink/pull/7048#issuecomment-437860559
@StefanRRichter I only have one final comment about the while loop.
Other than that, this LGTM 👍
-
[
https://issues.apache.org/jira/browse/FLINK-10809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16683716#comment-16683716
]
ASF GitHub Bot commented on FLINK-10809:
tzulitai commented on a change in pull
tzulitai commented on a change in pull request #7048: [FLINK-10809][state]
Include keyed state that is not from head operat…
URL: https://github.com/apache/flink/pull/7048#discussion_r232637615
##
File path:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/datastre
[
https://issues.apache.org/jira/browse/FLINK-9311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16683711#comment-16683711
]
ASF GitHub Bot commented on FLINK-9311:
---
nielsbasjes commented on a change in pull
nielsbasjes commented on a change in pull request #6594: [FLINK-9311] [pubsub]
Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)
URL: https://github.com/apache/flink/pull/6594#discussion_r232637001
##
File path:
flink-connectors/flink-connector-pubsub/src/
[
https://issues.apache.org/jira/browse/FLINK-9311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16683683#comment-16683683
]
ASF GitHub Bot commented on FLINK-9311:
---
nielsbasjes commented on a change in pull
[
https://issues.apache.org/jira/browse/FLINK-9311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16683707#comment-16683707
]
ASF GitHub Bot commented on FLINK-9311:
---
nielsbasjes commented on a change in pull
1 - 100 of 269 matches
Mail list logo
