[
https://issues.apache.org/jira/browse/FLINK-9343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472921#comment-16472921
]
ASF GitHub Bot commented on FLINK-9343:
---
GitHub user medcv opened a pull request:
GitHub user medcv opened a pull request:
https://github.com/apache/flink/pull/5996
[FLINK-9343] [Example] Add Async Example with External Rest API call
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server,
Yazdan Shirvany created FLINK-9343:
--
Summary: Add Async Example with External Rest API call
Key: FLINK-9343
URL: https://issues.apache.org/jira/browse/FLINK-9343
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-9342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-9342:
Summary: Conflicted url path pattern about
SubtaskCurrentAttemptDetailsHeaders and
[
https://issues.apache.org/jira/browse/FLINK-9342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472856#comment-16472856
]
vinoyang commented on FLINK-9342:
-
like FLINK-9339
> conflicted url path pattern about
[
https://issues.apache.org/jira/browse/FLINK-9339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472855#comment-16472855
]
vinoyang commented on FLINK-9339:
-
another similar issue is FLINK-9342
> Accumulators are not UI
vinoyang created FLINK-9342:
---
Summary: conflicted url path pattern about
SubtaskCurrentAttemptDetailsHeaders and AggregatedSubtaskMetricsHeaders
Key: FLINK-9342
URL: https://issues.apache.org/jira/browse/FLINK-9342
[
https://issues.apache.org/jira/browse/FLINK-9339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472849#comment-16472849
]
vinoyang commented on FLINK-9339:
-
the reason because of , SubtaskCurrentAttemptDetailsHeaders used url
[
https://issues.apache.org/jira/browse/FLINK-9339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-9339:
---
Assignee: vinoyang
> Accumulators are not UI accessible running in FLIP-6 mode
>
[
https://issues.apache.org/jira/browse/FLINK-9332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-9332.
Resolution: Fixed
Fix Version/s: 1.5.0
Fixed for 1.5.0 with
[
https://issues.apache.org/jira/browse/FLINK-9341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ken Geis updated FLINK-9341:
Description:
When creating a Table from an Oracle JDBCInputFormat with a date column, I get
the error
[
https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-9138.
Resolution: Implemented
Fix Version/s: 1.6.0
Implemented for 1.6.0 with
[
https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472768#comment-16472768
]
ASF GitHub Bot commented on FLINK-9138:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-9332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472769#comment-16472769
]
ASF GitHub Bot commented on FLINK-9332:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5860
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5988
---
[
https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske reassigned FLINK-9138:
Assignee: Lakshmi Rao
> Enhance BucketingSink to also flush data by time interval
>
[
https://issues.apache.org/jira/browse/FLINK-9341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472751#comment-16472751
]
Fabian Hueske commented on FLINK-9341:
--
Hi, could you please include the full stacktrace of the
Ken Geis created FLINK-9341:
---
Summary: Oracle: "Type is not supported: Date"
Key: FLINK-9341
URL: https://issues.apache.org/jira/browse/FLINK-9341
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-9312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472692#comment-16472692
]
ASF GitHub Bot commented on FLINK-9312:
---
Github user EronWright commented on the issue:
Github user EronWright commented on the issue:
https://github.com/apache/flink/pull/5966
This looks great but let's please separate the intra-cluster SSL
configuration options from the external-cluster options. In particular, the
web/API endpoints should be governed by a different
Ted Yu created FLINK-9340:
-
Summary: ScheduleOrUpdateConsumersTest may fail with Address
already in use
Key: FLINK-9340
URL: https://issues.apache.org/jira/browse/FLINK-9340
Project: Flink
Issue
GitHub user dawidwys opened a pull request:
https://github.com/apache/flink/pull/5995
[FLINK-9337] Implemented AvroDeserializationSchema
## What is the purpose of the change
Provides implementation of AvroDeserializationSchema that reads records
serialized as avro and also
[
https://issues.apache.org/jira/browse/FLINK-9337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472578#comment-16472578
]
ASF GitHub Bot commented on FLINK-9337:
---
GitHub user dawidwys opened a pull request:
Github user dawidwys closed the pull request at:
https://github.com/apache/flink/pull/5994
---
[
https://issues.apache.org/jira/browse/FLINK-8866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472571#comment-16472571
]
Rong Rong commented on FLINK-8866:
--
Hi [~suez1224]
I was working on FLINK-8880 and I thought it will be
[
https://issues.apache.org/jira/browse/FLINK-9332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472560#comment-16472560
]
ASF GitHub Bot commented on FLINK-9332:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472559#comment-16472559
]
ASF GitHub Bot commented on FLINK-9138:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/5988
Merging
---
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/5860
Merging
---
[
https://issues.apache.org/jira/browse/FLINK-1044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472552#comment-16472552
]
Yazdan Shirvany commented on FLINK-1044:
This looks old but still useful for someone who work
[
https://issues.apache.org/jira/browse/FLINK-9332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472517#comment-16472517
]
ASF GitHub Bot commented on FLINK-9332:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5988#discussion_r187710610
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/calls/CallGenerator.scala
---
@@ -64,17 +65,28 @@ object CallGenerator
Cliff Resnick created FLINK-9339:
Summary: Accumulators are not UI accessible running in FLIP-6 mode
Key: FLINK-9339
URL: https://issues.apache.org/jira/browse/FLINK-9339
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-9325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472330#comment-16472330
]
ASF GitHub Bot commented on FLINK-9325:
---
Github user sihuazhou commented on the issue:
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/5982
Hi @StephanEwen,
- I prefer to introduce the `create(Path, WriteMode)`, because I feel this
is more extensible (it could allow us to introduce other WriteMode's in the
future).
- I would
[
https://issues.apache.org/jira/browse/FLINK-8982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472297#comment-16472297
]
ASF GitHub Bot commented on FLINK-8982:
---
Github user kl0u commented on a diff in the pull request:
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/5807#discussion_r187677168
--- Diff:
flink-end-to-end-tests/flink-queryable-state-test/src/main/java/org/apache/flink/streaming/tests/queryablestate/QsStateProducer.java
---
@@ -0,0
[
https://issues.apache.org/jira/browse/FLINK-8982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472294#comment-16472294
]
ASF GitHub Bot commented on FLINK-8982:
---
Github user kl0u commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472291#comment-16472291
]
ASF GitHub Bot commented on FLINK-8982:
---
Github user kl0u commented on a diff in the pull request:
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/5807#discussion_r187676881
--- Diff:
flink-end-to-end-tests/test-scripts/test_queryable_state_restart_tm.sh ---
@@ -0,0 +1,120 @@
+#!/usr/bin/env bash
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/5807#discussion_r187676635
--- Diff:
flink-end-to-end-tests/test-scripts/test_queryable_state_restart_tm.sh ---
@@ -0,0 +1,120 @@
+#!/usr/bin/env bash
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/5807#discussion_r187675826
--- Diff:
flink-end-to-end-tests/test-scripts/test_queryable_state_restart_tm.sh ---
@@ -0,0 +1,120 @@
+#!/usr/bin/env bash
[
https://issues.apache.org/jira/browse/FLINK-8982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472286#comment-16472286
]
ASF GitHub Bot commented on FLINK-8982:
---
Github user kl0u commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472283#comment-16472283
]
ASF GitHub Bot commented on FLINK-8982:
---
Github user kl0u commented on a diff in the pull request:
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/5807#discussion_r187675012
--- Diff: flink-end-to-end-tests/flink-queryable-state-test/pom.xml ---
@@ -0,0 +1,134 @@
+
+
+http://maven.apache.org/POM/4.0.0;
+
GitHub user dawidwys opened a pull request:
https://github.com/apache/flink/pull/5994
Avro deserializer2
## What is the purpose of the change
Provides implementation of AvroDeserializationSchema that reads records
serialized as avro and also provides version that uses Confluent
[
https://issues.apache.org/jira/browse/FLINK-8982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472275#comment-16472275
]
ASF GitHub Bot commented on FLINK-8982:
---
Github user kl0u commented on a diff in the pull request:
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/5807#discussion_r187674099
--- Diff:
flink-end-to-end-tests/flink-queryable-state-test/src/main/java/org/apache/flink/streaming/tests/queryablestate/QsStateProducer.java
---
@@ -0,0
[
https://issues.apache.org/jira/browse/FLINK-9336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472273#comment-16472273
]
ASF GitHub Bot commented on FLINK-9336:
---
Github user kl0u commented on the issue:
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/5993
Thanks for the work @sihuazhou and for reporting this @florianschmidt1994 !
This fixes the problem described in the JIRA but I will look at the PR a bit
more thoroughly on Monday at the latest and then
Dawid Wysakowicz created FLINK-9337:
---
Summary: Implement AvroDeserializationSchema
Key: FLINK-9337
URL: https://issues.apache.org/jira/browse/FLINK-9337
Project: Flink
Issue Type: New
Dawid Wysakowicz created FLINK-9338:
---
Summary: Implement RegistryAvroDeserializationSchema
Key: FLINK-9338
URL: https://issues.apache.org/jira/browse/FLINK-9338
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-9336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou updated FLINK-9336:
--
Fix Version/s: 1.5.0
> Queryable state fails with Exception after task manager restore
>
[
https://issues.apache.org/jira/browse/FLINK-9325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472191#comment-16472191
]
ASF GitHub Bot commented on FLINK-9325:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5982
How about adding the method `createAtomically` or so, with otherwise the
same signature as the `create(Path, WriteMode)` method?
---
[
https://issues.apache.org/jira/browse/FLINK-8949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472156#comment-16472156
]
Esteban Serrano commented on FLINK-8949:
Running into a similar problem with the REST API to
[
https://issues.apache.org/jira/browse/FLINK-9336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472123#comment-16472123
]
ASF GitHub Bot commented on FLINK-9336:
---
Github user sihuazhou commented on the issue:
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/5993
cc @StefanRRichter, @kl0u you may also care about this...
---
[
https://issues.apache.org/jira/browse/FLINK-9336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472121#comment-16472121
]
ASF GitHub Bot commented on FLINK-9336:
---
GitHub user sihuazhou opened a pull request:
GitHub user sihuazhou opened a pull request:
https://github.com/apache/flink/pull/5993
[FLINK-9336][state] fix deserialization problem for queryable MapState
## What is the purpose of the change
This PR fixes the deserialization problem for queryable MapState. Currently
[
https://issues.apache.org/jira/browse/FLINK-9336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou updated FLINK-9336:
--
Priority: Blocker (was: Major)
> Queryable state fails with Exception after task manager restore
>
[
https://issues.apache.org/jira/browse/FLINK-8944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472109#comment-16472109
]
ASF GitHub Bot commented on FLINK-8944:
---
Github user kailashhd commented on the issue:
Github user kailashhd commented on the issue:
https://github.com/apache/flink/pull/5992
R: @tzulitai @tweise
---
[
https://issues.apache.org/jira/browse/FLINK-9303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472108#comment-16472108
]
ASF GitHub Bot commented on FLINK-9303:
---
Github user tedyu commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-9303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472107#comment-16472107
]
ASF GitHub Bot commented on FLINK-9303:
---
Github user tedyu commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-9303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472106#comment-16472106
]
ASF GitHub Bot commented on FLINK-9303:
---
Github user tedyu commented on a diff in the pull request:
Github user tedyu commented on a diff in the pull request:
https://github.com/apache/flink/pull/5991#discussion_r187647275
--- Diff:
flink-connectors/flink-connector-kafka-0.8/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer08.java
---
@@ -221,7 +221,8
Github user tedyu commented on a diff in the pull request:
https://github.com/apache/flink/pull/5991#discussion_r187648458
--- Diff:
flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/KafkaConsumerThread.java
---
@@
Github user tedyu commented on a diff in the pull request:
https://github.com/apache/flink/pull/5991#discussion_r187647828
--- Diff:
flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/KafkaConsumerThread.java
---
@@ -80,6
[
https://issues.apache.org/jira/browse/FLINK-9295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472085#comment-16472085
]
ASF GitHub Bot commented on FLINK-9295:
---
Github user pnowojski commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472086#comment-16472086
]
ASF GitHub Bot commented on FLINK-9295:
---
Github user pnowojski commented on a diff in the pull
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5977#discussion_r187646041
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/functions/RuntimeContext.java
---
@@ -71,6 +71,17 @@
@PublicEvolving
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5977#discussion_r187645022
--- Diff:
flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java
---
@@ -837,7
[
https://issues.apache.org/jira/browse/FLINK-9036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472083#comment-16472083
]
ASF GitHub Bot commented on FLINK-9036:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5735
@aljoscha Would be interested in your opinion here.
This is basically one of two ways to improve the handling of default values:
1. Add a default value supplier on the state
[
https://issues.apache.org/jira/browse/FLINK-9336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou reassigned FLINK-9336:
-
Assignee: Sihua Zhou
> Queryable state fails with Exception after task manager restore
>
[
https://issues.apache.org/jira/browse/FLINK-9336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472078#comment-16472078
]
Sihua Zhou commented on FLINK-9336:
---
[~florianschmidt] Thanks for reporting this bug, in fact this is a
[
https://issues.apache.org/jira/browse/FLINK-9292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472066#comment-16472066
]
ASF GitHub Bot commented on FLINK-9292:
---
Github user yanghua commented on the issue:
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/5970
cc @StephanEwen refactored based on your suggestion, the travis build
failed because of yarn test, seems not about this PR's change.
---
[
https://issues.apache.org/jira/browse/FLINK-9295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472055#comment-16472055
]
ASF GitHub Bot commented on FLINK-9295:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472056#comment-16472056
]
ASF GitHub Bot commented on FLINK-9295:
---
Github user StephanEwen commented on a diff in the pull
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/5977#discussion_r187639708
--- Diff:
flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java
---
@@
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/5977#discussion_r187640541
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/functions/RuntimeContext.java
---
@@ -71,6 +71,17 @@
@PublicEvolving
Github user GJL closed the pull request at:
https://github.com/apache/flink/pull/5973
---
[
https://issues.apache.org/jira/browse/FLINK-9261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472049#comment-16472049
]
ASF GitHub Bot commented on FLINK-9261:
---
Github user GJL closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-9332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472026#comment-16472026
]
ASF GitHub Bot commented on FLINK-9332:
---
Github user Xpray commented on a diff in the pull request:
Github user Xpray commented on a diff in the pull request:
https://github.com/apache/flink/pull/5988#discussion_r187636663
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/calls/CallGenerator.scala
---
@@ -64,17 +65,28 @@ object CallGenerator {
[
https://issues.apache.org/jira/browse/FLINK-9332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472023#comment-16472023
]
ASF GitHub Bot commented on FLINK-9332:
---
Github user Xpray commented on a diff in the pull request:
Github user Xpray commented on a diff in the pull request:
https://github.com/apache/flink/pull/5988#discussion_r187636169
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/calls/CallGenerator.scala
---
@@ -64,17 +65,28 @@ object CallGenerator {
[
https://issues.apache.org/jira/browse/FLINK-9336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Florian Schmidt updated FLINK-9336:
---
Description:
The following steps can be used to reproduce the Exception:
# Run an app
[
https://issues.apache.org/jira/browse/FLINK-9336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Florian Schmidt updated FLINK-9336:
---
Description:
The following steps can be used to reproduce the Exception:
# Run an app
Florian Schmidt created FLINK-9336:
--
Summary: Queryable state fails with Exception after task manager
restore
Key: FLINK-9336
URL: https://issues.apache.org/jira/browse/FLINK-9336
Project: Flink
Github user kailashhd commented on a diff in the pull request:
https://github.com/apache/flink/pull/5992#discussion_r187632455
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/ConsumerConfigConstants.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-8944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472009#comment-16472009
]
ASF GitHub Bot commented on FLINK-8944:
---
Github user kailashhd commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472004#comment-16472004
]
ASF GitHub Bot commented on FLINK-8944:
---
Github user kailashhd commented on a diff in the pull
Github user kailashhd commented on a diff in the pull request:
https://github.com/apache/flink/pull/5992#discussion_r187630051
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/ConsumerConfigConstants.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-8944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472001#comment-16472001
]
ASF GitHub Bot commented on FLINK-8944:
---
Github user tweise commented on a diff in the pull request:
Github user tweise commented on a diff in the pull request:
https://github.com/apache/flink/pull/5992#discussion_r187627524
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/ConsumerConfigConstants.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-8944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471994#comment-16471994
]
ASF GitHub Bot commented on FLINK-8944:
---
GitHub user kailashhd opened a pull request:
1 - 100 of 175 matches
Mail list logo
