flinkbot commented on issue #8146: [FLINK-11799][Connectors]Make KryoSerializer
aware of exceptions occu…
URL: https://github.com/apache/flink/pull/8146#issuecomment-481990361
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to revi
[
https://issues.apache.org/jira/browse/FLINK-11799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16815127#comment-16815127
]
Liya Fan commented on FLINK-11799:
--
Hi [~longtimer], thanks a lot for your feedback. I
liyafan82 opened a new pull request #8146: [FLINK-11799][Connectors]Make
KryoSerializer aware of exceptions occu…
URL: https://github.com/apache/flink/pull/8146
…red during copying
## What is the purpose of the change
To resolve issue 11799. In particular, when the Kry
[
https://issues.apache.org/jira/browse/FLINK-11799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11799:
---
Labels: pull-request-available (was: )
> KryoSerializer/OperatorChain ignores copy failure
KurtYoung commented on a change in pull request #8127:
[FLINK-12140][table-planner-blink] Support e2e sort merge join operator in
batch mode
URL: https://github.com/apache/flink/pull/8127#discussion_r274280170
##
File path:
flink-table/flink-table-runtime-blink/src/test/java/org/a
KurtYoung commented on a change in pull request #8127:
[FLINK-12140][table-planner-blink] Support e2e sort merge join operator in
batch mode
URL: https://github.com/apache/flink/pull/8127#discussion_r274280142
##
File path:
flink-table/flink-table-runtime-blink/src/test/java/org/a
KurtYoung commented on a change in pull request #8127:
[FLINK-12140][table-planner-blink] Support e2e sort merge join operator in
batch mode
URL: https://github.com/apache/flink/pull/8127#discussion_r274278517
##
File path:
flink-table/flink-table-planner-blink/src/main/scala/org/
KurtYoung commented on a change in pull request #8127:
[FLINK-12140][table-planner-blink] Support e2e sort merge join operator in
batch mode
URL: https://github.com/apache/flink/pull/8127#discussion_r274279491
##
File path:
flink-table/flink-table-planner-blink/src/main/scala/org/
KurtYoung commented on a change in pull request #8127:
[FLINK-12140][table-planner-blink] Support e2e sort merge join operator in
batch mode
URL: https://github.com/apache/flink/pull/8127#discussion_r274279808
##
File path:
flink-table/flink-table-planner-blink/src/test/scala/org/
fhueske commented on issue #6684: [FLINK-10205] Batch Job: InputSplit Fault
tolerant for DataSource…
URL: https://github.com/apache/flink/pull/6684#issuecomment-481987632
PR #8125 got merged.
Closing this PR.
Thanks, Fabian
---
fhueske closed pull request #6684: [FLINK-10205] Batch Job: InputSplit
Fault tolerant for DataSource…
URL: https://github.com/apache/flink/pull/6684
This is an automated message from the Apache Git Service.
To respond to
[
https://issues.apache.org/jira/browse/FLINK-12131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-12131:
Description:
Two status may not be correct with region failover and current reset logic.
# *numberOfRunni
sunjincheng121 commented on a change in pull request #8087:
[FLINK-12029][table] Add column operations for TableApi
URL: https://github.com/apache/flink/pull/8087#discussion_r274272456
##
File path: docs/dev/table/functions.md
##
@@ -5800,3 +5800,284 @@ For Table API, plea
[
https://issues.apache.org/jira/browse/FLINK-12131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-12131:
Description:
Two status may not be correct with region failover and current reset logic.
# *numberOfRunni
sunjincheng121 commented on a change in pull request #8087:
[FLINK-12029][table] Add column operations for TableApi
URL: https://github.com/apache/flink/pull/8087#discussion_r274271870
##
File path: docs/dev/table/functions.md
##
@@ -5800,3 +5800,284 @@ For Table API, plea
sunjincheng121 commented on a change in pull request #8087:
[FLINK-12029][table] Add column operations for TableApi
URL: https://github.com/apache/flink/pull/8087#discussion_r274272514
##
File path: docs/dev/table/functions.md
##
@@ -5800,3 +5800,284 @@ For Table API, plea
[
https://issues.apache.org/jira/browse/FLINK-12131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16815110#comment-16815110
]
Zhu Zhu commented on FLINK-12131:
-
Hi [~till.rohrmann], I think this fix is needed to ma
[
https://issues.apache.org/jira/browse/FLINK-12131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-12131:
Description:
Two status may not be correct with region failover and current reset logic.
# *numberOfRunni
[
https://issues.apache.org/jira/browse/FLINK-12098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young closed FLINK-12098.
--
Resolution: Fixed
Fix Version/s: 1.9.0
fixed in 517a04f1cbe74d10340b1cb17eb2b4a1b1b11195
> Add
KurtYoung merged pull request #8110: [FLINK-12098] [table-planner-blink] Add
support for generating optimized logical plan for simple group aggregate on
stream
URL: https://github.com/apache/flink/pull/8110
This is an autom
carp84 commented on issue #8078: [FLINK-12066] [State Backends] Remove
StateSerializerProvider field in keyed state backends
URL: https://github.com/apache/flink/pull/8078#issuecomment-481977232
Thanks for review and help merge! @tzulitai
--
sunjincheng121 commented on a change in pull request #8007:
[FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other …
URL: https://github.com/apache/flink/pull/8007#discussion_r274267713
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flin
sunjincheng121 commented on a change in pull request #8007:
[FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other …
URL: https://github.com/apache/flink/pull/8007#discussion_r274267157
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flin
hequn8128 commented on issue #8087: [FLINK-12029][table] Add column operations
for TableApi
URL: https://github.com/apache/flink/pull/8087#issuecomment-481972396
@sunjincheng121 @dawidwys I have updated the PR. Would be great if you can
take another look. :-)
-
zhijiangW commented on issue #8090: [FLINK-12067][network] Refactor the
constructor of NetworkEnvironment
URL: https://github.com/apache/flink/pull/8090#issuecomment-481971372
@pnowojski , thanks for your review! I have rebased the master to solve the
conflicts.
--
zentol commented on a change in pull request #8002: [FLINK-11923][metrics]
MetricRegistryConfiguration provides MetricReporters Suppliers
URL: https://github.com/apache/flink/pull/8002#discussion_r274009874
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/metrics/
zentol commented on a change in pull request #8002: [FLINK-11923][metrics]
MetricRegistryConfiguration provides MetricReporters Suppliers
URL: https://github.com/apache/flink/pull/8002#discussion_r274009874
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/metrics/
[
https://issues.apache.org/jira/browse/FLINK-10929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16815073#comment-16815073
]
vinoyang commented on FLINK-10929:
--
Hi [~fan_li_ya] If there is any design documentatio
hequn8128 commented on issue #8050: [FLINK-11067][table] Convert
TableEnvironments to interfaces
URL: https://github.com/apache/flink/pull/8050#issuecomment-481965728
@bowenli86 Thanks for your review and providing valuable information for the
catalog.
- Re TableEnvironment.
Yes,
asfgit closed pull request #8078: [FLINK-12066] [State Backends] Remove
StateSerializerProvider field in keyed state backends
URL: https://github.com/apache/flink/pull/8078
This is an automated message from the Apache Git Se
[
https://issues.apache.org/jira/browse/FLINK-12066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai closed FLINK-12066.
---
Resolution: Fixed
Merged for 1.9.0:
1132a52a58c3710a9a183111fda84cd1432605fa
> Remo
tzulitai commented on issue #8078: [FLINK-12066] [State Backends] Remove
StateSerializerProvider field in keyed state backends
URL: https://github.com/apache/flink/pull/8078#issuecomment-481962227
Thanks, merging ..
This is a
KurtYoung commented on issue #8110: [FLINK-12098] [table-planner-blink] Add
support for generating optimized logical plan for simple group aggregate on
stream
URL: https://github.com/apache/flink/pull/8110#issuecomment-481956259
LGTM, +1 to merge
--
[
https://issues.apache.org/jira/browse/FLINK-11935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16815059#comment-16815059
]
vinoyang commented on FLINK-11935:
--
[~walterddr] It seems I found the key issue, and we
[
https://issues.apache.org/jira/browse/FLINK-12140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-12140:
-
Summary: Support e2e sort merge join operator in batch mode (was: Support
sort merge join it ca
zjffdu commented on issue #8144: [FLINK-12159]. Enable YarnMiniCluster
integration test under non-secure mode
URL: https://github.com/apache/flink/pull/8144#issuecomment-481952307
@tillrohrmann Could you help review it ? Thanks
-
[
https://issues.apache.org/jira/browse/FLINK-11813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16815027#comment-16815027
]
Zhu Zhu edited comment on FLINK-11813 at 4/11/19 3:30 AM:
--
Hi T
[
https://issues.apache.org/jira/browse/FLINK-12140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16815052#comment-16815052
]
Kurt Young commented on FLINK-12140:
you could just say support e2e join operator
hequn8128 commented on a change in pull request #8087: [FLINK-12029][table] Add
column operations for TableApi
URL: https://github.com/apache/flink/pull/8087#discussion_r274246117
##
File path:
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/api/tableImpl.scal
hequn8128 commented on a change in pull request #8087: [FLINK-12029][table] Add
column operations for TableApi
URL: https://github.com/apache/flink/pull/8087#discussion_r274245850
##
File path:
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/api/tableImpl.scal
[
https://issues.apache.org/jira/browse/FLINK-11813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16815027#comment-16815027
]
Zhu Zhu edited comment on FLINK-11813 at 4/11/19 2:47 AM:
--
Hi T
zhijiangW commented on issue #8136: [FLINK-12154][network] Remove legacy fields
for SingleInputGate
URL: https://github.com/apache/flink/pull/8136#issuecomment-481943959
Thanks for your review @azagrebin .
I checked the travis result and the failure is not related to my changes.
---
[
https://issues.apache.org/jira/browse/FLINK-11813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16815027#comment-16815027
]
Zhu Zhu commented on FLINK-11813:
-
Hi Till, for your 2 questions above:
1. If one job w
carp84 commented on issue #8078: [FLINK-12066] [State Backends] Remove
StateSerializerProvider field in keyed state backends
URL: https://github.com/apache/flink/pull/8078#issuecomment-481940313
Checking the travis log and the error (as shown below) is irrelative to
change here, will rebas
jonpollock edited a comment on issue #7458: [FLINK-11302] FlinkS3FileSystem
uses an incorrect path for temporary files.
URL: https://github.com/apache/flink/pull/7458#issuecomment-481939883
I know this is already closed and merged, but I'd just like to point out
that the constructor of the
jonpollock commented on issue #7458: [FLINK-11302] FlinkS3FileSystem uses an
incorrect path for temporary files.
URL: https://github.com/apache/flink/pull/7458#issuecomment-481939883
I know this is already closed and merged, but I'd just like to point out
that the constructor of the FlinkS
zjffdu commented on a change in pull request #8038: [FLINK-11953] Introduce
Plugin/Loading system and integrate it with FileSystem
URL: https://github.com/apache/flink/pull/8038#discussion_r274236430
##
File path:
flink-core/src/main/java/org/apache/flink/core/plugin/DirectoryBased
zhijiangW commented on a change in pull request #8090: [FLINK-12067][network]
Refactor the constructor of NetworkEnvironment
URL: https://github.com/apache/flink/pull/8090#discussion_r274236223
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/NetworkEn
zjffdu commented on a change in pull request #8038: [FLINK-11953] Introduce
Plugin/Loading system and integrate it with FileSystem
URL: https://github.com/apache/flink/pull/8038#discussion_r274235386
##
File path:
flink-core/src/main/java/org/apache/flink/core/plugin/PluginUtils.ja
[
https://issues.apache.org/jira/browse/FLINK-10929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16815009#comment-16815009
]
Liya Fan commented on FLINK-10929:
--
We have imported Arrow in our efforts to vectorize
[
https://issues.apache.org/jira/browse/FLINK-11654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengnan YU updated FLINK-11654:
Comment: was deleted
(was: Hi, I got the same problem, any updated solution here?)
> Multiple tra
[
https://issues.apache.org/jira/browse/FLINK-11654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16815006#comment-16815006
]
Shengnan YU commented on FLINK-11654:
-
Hi, I got the same problem, any updated solut
zjffdu commented on a change in pull request #8038: [FLINK-11953] Introduce
Plugin/Loading system and integrate it with FileSystem
URL: https://github.com/apache/flink/pull/8038#discussion_r274232242
##
File path:
flink-core/src/main/java/org/apache/flink/core/plugin/DirectoryBased
[
https://issues.apache.org/jira/browse/FLINK-12160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-12160:
--
Issue Type: Sub-task (was: New Feature)
Parent: FLINK-9953
> Support for transferring user co
Yang Wang created FLINK-12160:
-
Summary: Support for transferring user config files on kubernetes
Key: FLINK-12160
URL: https://issues.apache.org/jira/browse/FLINK-12160
Project: Flink
Issue Type
[
https://issues.apache.org/jira/browse/FLINK-11799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Liya Fan reassigned FLINK-11799:
Assignee: Liya Fan
> KryoSerializer/OperatorChain ignores copy failure resulting in
> NullPointe
flinkbot commented on issue #8145: Inst 1.8.0
URL: https://github.com/apache/flink/pull/8145#issuecomment-481884659
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the p
DarqueBox opened a new pull request #8145: Inst 1.8.0
URL: https://github.com/apache/flink/pull/8145
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way we avoid re-transferr
flinkbot edited a comment on issue #8136: [FLINK-12154][network] Remove legacy
fields for SingleInputGate
URL: https://github.com/apache/flink/pull/8136#issuecomment-481642495
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to revi
azagrebin commented on issue #8136: [FLINK-12154][network] Remove legacy fields
for SingleInputGate
URL: https://github.com/apache/flink/pull/8136#issuecomment-481822687
@flinkbot approve all
@flinkbot attention @pnowojski
---
[
https://issues.apache.org/jira/browse/FLINK-10049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16814703#comment-16814703
]
Hequn Cheng commented on FLINK-10049:
-
Yes, I meant to unify the logic for the two p
xuefuz commented on a change in pull request #8007: [FLINK-11474][table] Add
ReadableCatalog, ReadableWritableCatalog, and other …
URL: https://github.com/apache/flink/pull/8007#discussion_r274073139
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/table/
piyushnarang commented on a change in pull request #8117: [FLINK-12115]
[filesystems]: Add support for AzureFS
URL: https://github.com/apache/flink/pull/8117#discussion_r274070476
##
File path:
flink-filesystems/flink-azure-fs-hadoop/src/main/java/org/apache/flink/fs/azurefs/Abstra
tillrohrmann commented on a change in pull request #8002:
[FLINK-11923][metrics] MetricRegistryConfiguration provides MetricReporters
Suppliers
URL: https://github.com/apache/flink/pull/8002#discussion_r274057620
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/m
Myasuka commented on a change in pull request #8117: [FLINK-12115]
[filesystems]: Add support for AzureFS
URL: https://github.com/apache/flink/pull/8117#discussion_r274054284
##
File path:
flink-filesystems/flink-azure-fs-hadoop/src/main/java/org/apache/flink/fs/azurefs/AbstractAzu
[
https://issues.apache.org/jira/browse/FLINK-12153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz closed FLINK-12153.
Resolution: Invalid
Please reopen with translated title or reach out to the mailing list
GJL commented on a change in pull request #7986: [FLINK-10517][rest] Add
stability test
URL: https://github.com/apache/flink/pull/7986#discussion_r274039553
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/rest/compatibility/CompatibilityCheckResult.java
GJL commented on a change in pull request #7986: [FLINK-10517][rest] Add
stability test
URL: https://github.com/apache/flink/pull/7986#discussion_r274041784
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/rest/compatibility/CompatibilityCheckResult.java
GJL commented on a change in pull request #7986: [FLINK-10517][rest] Add
stability test
URL: https://github.com/apache/flink/pull/7986#discussion_r274040526
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/rest/compatibility/CompatibilityCheckResult.java
GJL commented on a change in pull request #7986: [FLINK-10517][rest] Add
stability test
URL: https://github.com/apache/flink/pull/7986#discussion_r274044893
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/rest/compatibility/CompatibilityRoutine.java
##
an0 commented on a change in pull request #8106: [FLINK-12092] [docs]Clarify
when `onTimer(...)` is called
URL: https://github.com/apache/flink/pull/8106#discussion_r274040206
##
File path: docs/dev/stream/operators/process_function.md
##
@@ -44,8 +44,8 @@ For fault-tolera
[
https://issues.apache.org/jira/browse/FLINK-11799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16814589#comment-16814589
]
Jason Kania commented on FLINK-11799:
-
Hi Liya,
Your approach seems reasonable.
dawidwys commented on issue #8050: [FLINK-11067][table] Convert
TableEnvironments to interfaces
URL: https://github.com/apache/flink/pull/8050#issuecomment-481752758
Hi @hequn8128,
I had another look and some discussion with @twalthr about this PR and we
came up with few ideas how to pr
GJL commented on a change in pull request #7986: [FLINK-10517][rest] Add
stability test
URL: https://github.com/apache/flink/pull/7986#discussion_r274038147
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/rest/compatibility/CompatibilityRoutine.java
##
GJL commented on a change in pull request #7986: [FLINK-10517][rest] Add
stability test
URL: https://github.com/apache/flink/pull/7986#discussion_r274038147
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/rest/compatibility/CompatibilityRoutine.java
##
GJL commented on a change in pull request #7986: [FLINK-10517][rest] Add
stability test
URL: https://github.com/apache/flink/pull/7986#discussion_r274038147
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/rest/compatibility/CompatibilityRoutine.java
##
GJL commented on a change in pull request #7986: [FLINK-10517][rest] Add
stability test
URL: https://github.com/apache/flink/pull/7986#discussion_r274033867
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/rest/compatibility/RestAPIStabilityTest.java
##
dawidwys commented on a change in pull request #8007: [FLINK-11474][table] Add
ReadableCatalog, ReadableWritableCatalog, and other …
URL: https://github.com/apache/flink/pull/8007#discussion_r273911156
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/tabl
pnowojski commented on a change in pull request #8090: [FLINK-12067][network]
Refactor the constructor of NetworkEnvironment
URL: https://github.com/apache/flink/pull/8090#discussion_r274017522
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/NetworkEn
zentol commented on a change in pull request #8002: [FLINK-11923][metrics]
MetricRegistryConfiguration provides MetricReporters Suppliers
URL: https://github.com/apache/flink/pull/8002#discussion_r274014721
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/metrics/
flinkbot commented on issue #8144: [FLINK-12159]. Enable YarnMiniCluster
integration test under non-secure mode
URL: https://github.com/apache/flink/pull/8144#issuecomment-481732968
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
t
[
https://issues.apache.org/jira/browse/FLINK-12159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-12159:
---
Labels: pull-request-available (was: )
> Enable YarnMiniCluster integration test under non-
zjffdu opened a new pull request #8144: [FLINK-12159]. Enable YarnMiniCluster
integration test under non-secure mode
URL: https://github.com/apache/flink/pull/8144
## What is the purpose of the change
I can not run flink in YarnMiniCluster for integration test because
yarn-site.xml is n
zentol commented on a change in pull request #8002: [FLINK-11923][metrics]
MetricRegistryConfiguration provides MetricReporters Suppliers
URL: https://github.com/apache/flink/pull/8002#discussion_r274009874
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/metrics/
aloyszhang commented on issue #8143: [hotfix][javadocs] remove redundant 'for
example' for InputFormat
URL: https://github.com/apache/flink/pull/8143#issuecomment-481727297
@zentol
This is an automated message from the Apach
flinkbot commented on issue #8143: [hotfix][javadocs] remove redundant 'for
example' for InputFormat
URL: https://github.com/apache/flink/pull/8143#issuecomment-481726995
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review yo
aloyszhang opened a new pull request #8143: [hotfix][javadocs] remove redundant
'for example' for InputFormat
URL: https://github.com/apache/flink/pull/8143
## What is the purpose of the change
This pull request remove the redundant 'for example' in javadoc of
InputFormat.
Jeff Zhang created FLINK-12159:
--
Summary: Enable YarnMiniCluster integration test under non-secure
mode
Key: FLINK-12159
URL: https://issues.apache.org/jira/browse/FLINK-12159
Project: Flink
Is
[
https://issues.apache.org/jira/browse/FLINK-12159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang reassigned FLINK-12159:
--
Assignee: Jeff Zhang
> Enable YarnMiniCluster integration test under non-secure mode
> --
tillrohrmann commented on a change in pull request #8002:
[FLINK-11923][metrics] MetricRegistryConfiguration provides MetricReporters
Suppliers
URL: https://github.com/apache/flink/pull/8002#discussion_r273998850
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/m
tillrohrmann commented on a change in pull request #8002:
[FLINK-11923][metrics] MetricRegistryConfiguration provides MetricReporters
Suppliers
URL: https://github.com/apache/flink/pull/8002#discussion_r273995787
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/m
tillrohrmann commented on a change in pull request #8002:
[FLINK-11923][metrics] MetricRegistryConfiguration provides MetricReporters
Suppliers
URL: https://github.com/apache/flink/pull/8002#discussion_r273994424
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/m
tillrohrmann commented on a change in pull request #8116: [FLINK-11920][scala]
Reuse java classpath
URL: https://github.com/apache/flink/pull/8116#discussion_r273992844
##
File path:
flink-scala/src/test/scala/org/apache/flink/api/scala/typeutils/EnumValueSerializerUpgradeTest.scal
tzulitai removed a comment on issue #8140: [FLINK-12151][es1] Remove
Elasticsearch 1 connector
URL: https://github.com/apache/flink/pull/8140#issuecomment-481703278
@flinkbot approve all
This is an automated message from the
flinkbot edited a comment on issue #8140: [FLINK-12151][es1] Remove
Elasticsearch 1 connector
URL: https://github.com/apache/flink/pull/8140#issuecomment-481656785
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pul
tzulitai commented on issue #8140: [FLINK-12151][es1] Remove Elasticsearch 1
connector
URL: https://github.com/apache/flink/pull/8140#issuecomment-481703278
@flinkbot approve all
This is an automated message from the Apache
tzulitai commented on a change in pull request #8140: [FLINK-12151][es1] Remove
Elasticsearch 1 connector
URL: https://github.com/apache/flink/pull/8140#discussion_r273973666
##
File path: docs/dev/connectors/elasticsearch.md
##
@@ -82,54 +77,6 @@ Elasticsearch cluster.
[
https://issues.apache.org/jira/browse/FLINK-12158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
leesf closed FLINK-12158.
-
Resolution: Duplicate
> Update Java / Scala StatefulJobWBroadcastStateMigrationITCase for 1.8
>
[
https://issues.apache.org/jira/browse/FLINK-12158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
leesf updated FLINK-12158:
--
Summary: Update Java / Scala StatefulJobWBroadcastStateMigrationITCase for
1.8 (was: Update Java / Scala Stat
leesf created FLINK-12158:
-
Summary: Update Java / Scala
StatefulJobWBroadcastStateMigrationITCase for 1.7
Key: FLINK-12158
URL: https://issues.apache.org/jira/browse/FLINK-12158
Project: Flink
Issu
1 - 100 of 245 matches
Mail list logo
