alexeyt820 commented on a change in pull request #6615: [FLINK-8354]
[flink-connectors] Add ability to access and provider Kafka headers
URL: https://github.com/apache/flink/pull/6615#discussion_r249637189
##
File path:
flink-connectors/flink-connector-kafka-base/src/main/java/org/
alexeyt820 commented on a change in pull request #6615: [FLINK-8354]
[flink-connectors] Add ability to access and provider Kafka headers
URL: https://github.com/apache/flink/pull/6615#discussion_r249637189
##
File path:
flink-connectors/flink-connector-kafka-base/src/main/java/org/
alexeyt820 commented on a change in pull request #6615: [FLINK-8354]
[flink-connectors] Add ability to access and provider Kafka headers
URL: https://github.com/apache/flink/pull/6615#discussion_r249637422
##
File path:
flink-connectors/flink-connector-kafka-0.8/src/main/java/org/a
Myasuka closed pull request #7525: [FLINK-11363][test] Check and remove
TaskManagerConfigurationTest
URL: https://github.com/apache/flink/pull/7525
This is an automated message from the Apache Git Service.
To respond to the
Myasuka opened a new pull request #7525: [FLINK-11363][test] Check and remove
TaskManagerConfigurationTest
URL: https://github.com/apache/flink/pull/7525
## What is the purpose of the change
Check whether `TaskManagerConfigurationTest` contains any relevant tests for
the new code ba
zhijiang created FLINK-11403:
Summary: Remove ResultPartitionConsumableNotifier from
ResultPartition
Key: FLINK-11403
URL: https://issues.apache.org/jira/browse/FLINK-11403
Project: Flink
Issue
alexeyt820 commented on a change in pull request #6615: [FLINK-8354]
[flink-connectors] Add ability to access and provider Kafka headers
URL: https://github.com/apache/flink/pull/6615#discussion_r249637189
##
File path:
flink-connectors/flink-connector-kafka-base/src/main/java/org/
Aitozi commented on issue #7543: [FLINK-10996]Fix the possible state leak with
CEP processing time model
URL: https://github.com/apache/flink/pull/7543#issuecomment-456284633
Hi @dawidwys
I have gone through the `FLINK-7384`, I think the unified solution is more
clear. Maybe better che
Aitozi removed a comment on issue #7543: [FLINK-10996]Fix the possible state
leak with CEP processing time model
URL: https://github.com/apache/flink/pull/7543#issuecomment-456284633
Hi @dawidwys
I have gone through the `FLINK-7384`, I think the unified solution is more
clear. Maybe be
Aitozi commented on issue #4514: [FLINK-7384][cep] Unify event and processing
time handling in the Abs…
URL: https://github.com/apache/flink/pull/4514#issuecomment-456284959
Hi @dawidwys
I have gone through this PR, I think the unified solution is more clear.
Maybe better check about th
alexeyt820 commented on a change in pull request #6615: [FLINK-8354]
[flink-connectors] Add ability to access and provider Kafka headers
URL: https://github.com/apache/flink/pull/6615#discussion_r249653432
##
File path:
flink-connectors/flink-connector-kafka-0.11/src/main/java/org/
[
https://issues.apache.org/jira/browse/FLINK-9920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16748419#comment-16748419
]
Yun Tang commented on FLINK-9920:
-
Another instance: [https://api.travis-ci.org/v3/job/4
Myasuka opened a new pull request #7544: [FLINK-11366][tests] Port
TaskManagerMetricsTest to new code base
URL: https://github.com/apache/flink/pull/7544
## What is the purpose of the change
Port `TaskManagerMetricsTest` to new code base.
## Brief change log
- Move `T
Myasuka closed pull request #7544: [FLINK-11366][tests] Port
TaskManagerMetricsTest to new code base
URL: https://github.com/apache/flink/pull/7544
This is an automated message from the Apache Git Service.
To respond to the
Myasuka commented on issue #7525: [FLINK-11363][test] Check and remove
TaskManagerConfigurationTest
URL: https://github.com/apache/flink/pull/7525#issuecomment-456287098
I close-reopen this PR to rebuild checks for unexpected ITcase crashed (
refer to [FLINK-11380](https://issues.apache.or
Myasuka commented on issue #7544: [FLINK-11366][tests] Port
TaskManagerMetricsTest to new code base
URL: https://github.com/apache/flink/pull/7544#issuecomment-456287424
I close-reopen this PR to rebuild checks for unexpected ITcase broken (
refer to [FLINK-9920](https://issues.apache.org/
[
https://issues.apache.org/jira/browse/FLINK-11374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lining updated FLINK-11374:
---
Comment: was deleted
(was: agg by vertex
!image-2019-01-22-11-42-33-808.png!)
> See more failover and can
[
https://issues.apache.org/jira/browse/FLINK-11404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lining reassigned FLINK-11404:
--
Assignee: Yadong Xie (was: lining)
> web ui add see page and can filter by time
> --
lining created FLINK-11404:
--
Summary: web ui add see page and can filter by time
Key: FLINK-11404
URL: https://issues.apache.org/jira/browse/FLINK-11404
Project: Flink
Issue Type: Sub-task
lining created FLINK-11405:
--
Summary: rest api can see exception by start end time filter
Key: FLINK-11405
URL: https://issues.apache.org/jira/browse/FLINK-11405
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-10245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shimin Yang updated FLINK-10245:
Summary: Add HBase Streaming Sink (was: Add DataStream HBase Sink)
> Add HBase Streaming Sink
> -
zhijiangW opened a new pull request #7549: [FLINK-11403][network] Remove
ResultPartitionConsumableNotifier from ResultPartition
URL: https://github.com/apache/flink/pull/7549
## What is the purpose of the change
*This is the precondition for introducing pluggable `ShuffleService` on
[
https://issues.apache.org/jira/browse/FLINK-11403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11403:
---
Labels: pull-request-available (was: )
> Remove ResultPartitionConsumableNotifier from Resu
zhijiangW closed pull request #3340: [FLINK-5703] [Job Manager] ExecutionGraph
recovery via reconciliation with TaskManager reports
URL: https://github.com/apache/flink/pull/3340
This is an automated message from the Apache
zhijiangW commented on issue #3340: [FLINK-5703] [Job Manager] ExecutionGraph
recovery via reconciliation with TaskManager reports
URL: https://github.com/apache/flink/pull/3340#issuecomment-456296041
Close this pr temporarily, and this feature would be re-submitted if needed
in future.
-
[
https://issues.apache.org/jira/browse/FLINK-5703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-5703:
--
Labels: pull-request-available (was: )
> ExecutionGraph recovery based on reconciliation with
Clark opened a new pull request #7550: [FLINK-10245] [Streaming Connector]
Add Pojo, Tuple, Row and Scala Product DataStream Sink and Upsert Table Sink
for HBase
URL: https://github.com/apache/flink/pull/7550
## What is the purpose of the change
- Add datastream sink and upsert tabl
eaglewatcherwb commented on a change in pull request #7436: [FLINK-11071][core]
add support for dynamic proxy classes resolution …
URL: https://github.com/apache/flink/pull/7436#discussion_r249663932
##
File path:
flink-core/src/test/java/org/apache/flink/util/InstantiationUtilTest
lamber-ken opened a new pull request #7551: [hotfix][runtime] add default
statement in switch block when judge taskAcknowledgeResult
URL: https://github.com/apache/flink/pull/7551
## What is the purpose of the change
add default statement in switch block when judge taskAcknowledgeRes
101 - 129 of 129 matches
Mail list logo
