zentol merged pull request #7340: [FLINK-11174] [prometheus] Flink Metrics
Prometheus label values supp…
URL: https://github.com/apache/flink/pull/7340
This is an automated message from the Apache Git Service.
To respond to
libenchao opened a new pull request #7492: [FLINK-11311] [datastream] fix
StreamSource implements StreamOperator interface multiple times
URL: https://github.com/apache/flink/pull/7492
## What is the purpose of the change
*https://issues.apache.org/jira/browse/FLINK-11311*
*This pull
asfgit closed pull request #7384: [FLINK-11012] Introduce abstract superclass
for filesystem IT cases
URL: https://github.com/apache/flink/pull/7384
This is an automated message from the Apache Git Service.
To respond to
yanghua commented on a change in pull request #6876: [FLINK-10251] Handle
oversized response messages in AkkaRpcActor
URL: https://github.com/apache/flink/pull/6876#discussion_r248276958
##
File path:
zentol commented on a change in pull request #7303: [FLINK-10569] [tests] Get
rid of Scheduler from valid tests
URL: https://github.com/apache/flink/pull/7303#discussion_r248275777
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-10910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10910:
---
Labels: pull-request-available test-stability (was: test-stability)
> Harden Kubernetes
dawidwys opened a new pull request #7507: [FLINK-10910][e2e] Hardened
Kubernetes e2e test.
URL: https://github.com/apache/flink/pull/7507
Added check if minikube is running. If it is not we try to start it couple
of times. If we do not succeed we fail with a descriptive message.
##
zentol commented on a change in pull request #7459: [FLINK-10822] Make
MetricFetcher update interval configurable
URL: https://github.com/apache/flink/pull/7459#discussion_r248234523
##
File path:
flink-docs/src/main/java/org/apache/flink/docs/rest/RestAPIDocGenerator.java
StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State
TTL] TTL state incremental cleanup for heap backend
URL: https://github.com/apache/flink/pull/7188#discussion_r248240356
##
File path:
aljoscha commented on issue #7312: [FLINK-11169][runtime] fix the problem of
not being reloaded for jobmanager's…
URL: https://github.com/apache/flink/pull/7312#issuecomment-454741127
So basically have a new `LogFileHandler`, that has the functionality that we
need for log files from
[
https://issues.apache.org/jira/browse/FLINK-5018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16744099#comment-16744099
]
vinoyang commented on FLINK-5018:
-
[~tzulitai] Any suggestion?
> Make source idle timeout user
zentol commented on a change in pull request #7455: [FLINK-11288][build]
Exclude flink-ml from flink-dist
URL: https://github.com/apache/flink/pull/7455#discussion_r248312152
##
File path: flink-dist/src/main/assemblies/opt.xml
##
@@ -75,14 +75,6 @@
[
https://issues.apache.org/jira/browse/FLINK-11103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16744112#comment-16744112
]
vinoyang commented on FLINK-11103:
--
What do you think about Nico 's idea? I have not started this
tzulitai opened a new pull request #7504: [FLINK-10778] [tests] Extend
TypeSerializerSnapshotMigrationTestBase to test migrating from multiple versions
URL: https://github.com/apache/flink/pull/7504
## What is the purpose of the change
Prior to this PR, the
yanghua commented on a change in pull request #6876: [FLINK-10251] Handle
oversized response messages in AkkaRpcActor
URL: https://github.com/apache/flink/pull/6876#discussion_r248254237
##
File path:
zentol commented on a change in pull request #7245: [FLINK-11069] [utils]
Remove FutureUtil
URL: https://github.com/apache/flink/pull/7245#discussion_r248256295
##
File path:
zentol commented on issue #7312: [FLINK-11169][runtime] fix the problem of not
being reloaded for jobmanager's…
URL: https://github.com/apache/flink/pull/7312#issuecomment-454764098
I agree that we should have a dedicated `JobManagerLogFileHandler`
(similarly to what we have for
[
https://issues.apache.org/jira/browse/FLINK-11187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16743973#comment-16743973
]
Aljoscha Krettek commented on FLINK-11187:
--
Fixed on release-1.7 in
[
https://issues.apache.org/jira/browse/FLINK-11187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-11187.
Resolution: Fixed
> StreamingFileSink with S3 backend transient socket timeout issues
>
[
https://issues.apache.org/jira/browse/FLINK-11341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16743976#comment-16743976
]
Chesnay Schepler commented on FLINK-11341:
--
Why is this marked as resolved? Which commit fixed
[
https://issues.apache.org/jira/browse/FLINK-11012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-11012.
--
Resolution: Implemented
Merged in:
master: c08db3fda3
> Introduce abstract superclass for
StefanRRichter commented on a change in pull request #7351: [FLINK-11008][State
Backends, Checkpointing]SpeedUp upload state files using multithread
URL: https://github.com/apache/flink/pull/7351#discussion_r248267921
##
File path:
zentol commented on a change in pull request #7303: [FLINK-10569] [tests] Get
rid of Scheduler from valid tests
URL: https://github.com/apache/flink/pull/7303#discussion_r248273256
##
File path:
zjffdu commented on a change in pull request #7455: [FLINK-11288][build]
Exclude flink-ml from flink-dist
URL: https://github.com/apache/flink/pull/7455#discussion_r248273048
##
File path: flink-dist/src/main/assemblies/opt.xml
##
@@ -75,14 +75,6 @@
kannan created FLINK-11346:
--
Summary: Could not enable basic authentication with elastic search
connector
Key: FLINK-11346
URL: https://issues.apache.org/jira/browse/FLINK-11346
Project: Flink
zentol merged pull request #7505: [hotfix][docs] fix typo in large_state_tuning
doc
URL: https://github.com/apache/flink/pull/7505
This is an automated message from the Apache Git Service.
To respond to the message, please
tillrohrmann commented on a change in pull request #6876: [FLINK-10251] Handle
oversized response messages in AkkaRpcActor
URL: https://github.com/apache/flink/pull/6876#discussion_r248240992
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/rpc/SyncCallsTest.java
tillrohrmann commented on a change in pull request #6876: [FLINK-10251] Handle
oversized response messages in AkkaRpcActor
URL: https://github.com/apache/flink/pull/6876#discussion_r248241119
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/rpc/SyncCallsTest.java
tillrohrmann commented on a change in pull request #6876: [FLINK-10251] Handle
oversized response messages in AkkaRpcActor
URL: https://github.com/apache/flink/pull/6876#discussion_r248240734
##
File path:
tillrohrmann commented on a change in pull request #6876: [FLINK-10251] Handle
oversized response messages in AkkaRpcActor
URL: https://github.com/apache/flink/pull/6876#discussion_r248239441
##
File path:
tillrohrmann commented on a change in pull request #6876: [FLINK-10251] Handle
oversized response messages in AkkaRpcActor
URL: https://github.com/apache/flink/pull/6876#discussion_r248237931
##
File path:
tillrohrmann commented on a change in pull request #6876: [FLINK-10251] Handle
oversized response messages in AkkaRpcActor
URL: https://github.com/apache/flink/pull/6876#discussion_r248239219
##
File path:
tillrohrmann commented on a change in pull request #6876: [FLINK-10251] Handle
oversized response messages in AkkaRpcActor
URL: https://github.com/apache/flink/pull/6876#discussion_r248239038
##
File path:
tillrohrmann commented on a change in pull request #6876: [FLINK-10251] Handle
oversized response messages in AkkaRpcActor
URL: https://github.com/apache/flink/pull/6876#discussion_r248237741
##
File path:
tillrohrmann commented on a change in pull request #6876: [FLINK-10251] Handle
oversized response messages in AkkaRpcActor
URL: https://github.com/apache/flink/pull/6876#discussion_r248238265
##
File path:
zentol merged pull request #7456: [FLINK-11289][examples] Rework examples to
account for licensing
URL: https://github.com/apache/flink/pull/7456
This is an automated message from the Apache Git Service.
To respond to the
GJL commented on a change in pull request #7447: [FLINK-11294] [test] Remove
legacy JobInfo usage in valid tests
URL: https://github.com/apache/flink/pull/7447#discussion_r248261125
##
File path:
StefanRRichter commented on issue #7384: [FLINK-11012] Introduce abstract
superclass for filesystem IT cases
URL: https://github.com/apache/flink/pull/7384#issuecomment-454764386
LGTM Merging.
This is an automated message
StefanRRichter commented on issue #7384: [FLINK-11012] Introduce abstract
superclass for filesystem IT cases
URL: https://github.com/apache/flink/pull/7384#issuecomment-454766366
Thanks!
This is an automated message from the
dianfu commented on issue #7502: [hotfix][docs] Fix documentation of DataStream
API Tutorial
URL: https://github.com/apache/flink/pull/7502#issuecomment-454779281
@sunjincheng121 Thanks a lot for the review. Make sense to me. I have
updated the documentation based on connector kafka011.
aljoscha commented on issue #7493: [FLINK-11036] Fix
test_streaming_classloader.sh end-to-end test
URL: https://github.com/apache/flink/pull/7493#issuecomment-454779148
This succeeds on a travis run of mine:
https://travis-ci.org/aljoscha/flink/builds/480322513
[
https://issues.apache.org/jira/browse/FLINK-11302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas closed FLINK-11302.
--
Resolution: Fixed
Merged on master with 291373a0b61f4651ddbbaf0dc3f9dd9fd68db611
and on
pnowojski commented on a change in pull request #6787: [FLINK-8577][table]
Implement proctime DataStream to Table upsert conversion
URL: https://github.com/apache/flink/pull/6787#discussion_r247926320
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-11346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16744091#comment-16744091
]
Dawid Wysakowicz commented on FLINK-11346:
--
You should post those kind of question to user
[
https://issues.apache.org/jira/browse/FLINK-11346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz closed FLINK-11346.
Resolution: Not A Problem
> Could not enable basic authentication with elastic search
Fokko opened a new pull request #7508: [hotfix][docs] Add example for the
BulkFormat of the StreamingFileSink
URL: https://github.com/apache/flink/pull/7508
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
zentol commented on a change in pull request #7459: [FLINK-10822] Make
MetricFetcher update interval configurable
URL: https://github.com/apache/flink/pull/7459#discussion_r248240593
##
File path:
zentol closed pull request #4975: [FLINK-7991][examples][kafka] Cleanup kafka10
example jar
URL: https://github.com/apache/flink/pull/4975
This is an automated message from the Apache Git Service.
To respond to the message,
[
https://issues.apache.org/jira/browse/FLINK-10778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10778:
---
Labels: pull-request-available (was: )
> Update TypeSerializerSnapshotMigrationTestBase
[
https://issues.apache.org/jira/browse/FLINK-11174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-11174.
Resolution: Fixed
Fix Version/s: 1.8.0
master:
GJL commented on a change in pull request #7447: [FLINK-11294] [test] Remove
legacy JobInfo usage in valid tests
URL: https://github.com/apache/flink/pull/7447#discussion_r248262043
##
File path:
zentol closed pull request #7406: [FLINK-11259] Bump Zookeeper to 3.4.13
URL: https://github.com/apache/flink/pull/7406
This is an automated message from the Apache Git Service.
To respond to the message, please log on
wujinhu commented on issue #7384: [FLINK-11012] Introduce abstract superclass
for filesystem IT cases
URL: https://github.com/apache/flink/pull/7384#issuecomment-454766063
> But you said this was the same in the master, so it is would not be a
regression from this PR and can be fixed
wujinhu edited a comment on issue #7384: [FLINK-11012] Introduce abstract
superclass for filesystem IT cases
URL: https://github.com/apache/flink/pull/7384#issuecomment-454766063
> But you said this was the same in the master, so it is would not be a
regression from this PR and can be
StefanRRichter commented on a change in pull request #7351: [FLINK-11008][State
Backends, Checkpointing]SpeedUp upload state files using multithread
URL: https://github.com/apache/flink/pull/7351#discussion_r248269042
##
File path:
leesf opened a new pull request #7505: [hotfix][docs] fix typo in
large_state_tuning doc
URL: https://github.com/apache/flink/pull/7505
## What is the purpose of the change
Fix typo in large_state_tuning doc.
## Brief change log
Fix typo in large_state_tuning doc.
aljoscha commented on issue #7312: [FLINK-11169][runtime] fix the problem of
not being reloaded for jobmanager's…
URL: https://github.com/apache/flink/pull/7312#issuecomment-454740807
Yes, I think @jinglining's proposal is good. The `StaticFileServer` is meant
for "static" files, as the
[
https://issues.apache.org/jira/browse/FLINK-11187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16743882#comment-16743882
]
Aljoscha Krettek commented on FLINK-11187:
--
Fixed on master in
zentol commented on issue #7499: [FLINK-11340] Bump commons-configuration from
1.7 to 1.10
URL: https://github.com/apache/flink/pull/7499#issuecomment-454760399
What's the benefit?
This is an automated message from the
zentol commented on issue #7497: [FLINK-11338] Bump maven-enforcer-plugin from
3.0.0-M1 to 3.0.0-M2
URL: https://github.com/apache/flink/pull/7497#issuecomment-454760379
What's the benefit?
This is an automated message from
[
https://issues.apache.org/jira/browse/FLINK-11174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reopened FLINK-11174:
--
> flink Metrics Prometheus labels support chinese
>
zentol commented on issue #7498: [FLINK-11339] Bump exec-maven-plugin from
1.5.0 to 1.6.0
URL: https://github.com/apache/flink/pull/7498#issuecomment-454760388
What's the benefit?
This is an automated message from the Apache
zentol commented on issue #7406: [FLINK-11259] Bump Zookeeper to 3.4.13
URL: https://github.com/apache/flink/pull/7406#issuecomment-454762407
Please don't use the Apache Travis for debugging. I will close this PR; feel
free to re-open once you got a working solution.
wujinhu commented on issue #7384: [FLINK-11012] Introduce abstract superclass
for filesystem IT cases
URL: https://github.com/apache/flink/pull/7384#issuecomment-454765426
@StefanRRichter Thanks, but what about the issue I mentioned? Flink master
branch tests fail if I execute command in
Myasuka commented on issue #7475: [FLINK-11292][doc] Update document about how
to use new CompositeType…
URL: https://github.com/apache/flink/pull/7475#issuecomment-454765829
refactored according to your comments @tzulitai
StefanRRichter commented on issue #7384: [FLINK-11012] Introduce abstract
superclass for filesystem IT cases
URL: https://github.com/apache/flink/pull/7384#issuecomment-454765844
But you said this was the same in the master, so it is would not be a
regression from this PR and can be fixed
Fokko opened a new pull request #7506: [FLINK-11347] Optimize the
ParquetAvroWriters factory
URL: https://github.com/apache/flink/pull/7506
In the ParquetAvroWriters the schema is first serialized to a string, and
then back to a Schema, which is quite expensive to do. Therefore it makes
azagrebin commented on a change in pull request #7320: [FLINK-11171] Avoid
concurrent usage of StateSnapshotTransformer
URL: https://github.com/apache/flink/pull/7320#discussion_r248303966
##
File path:
zentol merged pull request #7471: [hotfix][docs] Update references to
deprecated SinkFunction#invoke(Object)
URL: https://github.com/apache/flink/pull/7471
This is an automated message from the Apache Git Service.
To
asfgit closed pull request #7255: [FLINK-10945] Use InputDependencyConstraint
to avoid resource dead…
URL: https://github.com/apache/flink/pull/7255
This is an automated message from the Apache Git Service.
To respond to
tillrohrmann commented on a change in pull request #7459: [FLINK-10822] Make
MetricFetcher update interval configurable
URL: https://github.com/apache/flink/pull/7459#discussion_r248280462
##
File path:
flink-docs/src/main/java/org/apache/flink/docs/rest/RestAPIDocGenerator.java
[
https://issues.apache.org/jira/browse/FLINK-11347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11347:
---
Labels: pull-request-available (was: )
> Optimize the ParquetAvroWriters factory
>
asfgit closed pull request #7458: [FLINK-11302] FlinkS3FileSystem uses an
incorrect path for temporary files.
URL: https://github.com/apache/flink/pull/7458
This is an automated message from the Apache Git Service.
To
pnowojski commented on a change in pull request #7440: [FLINK-10591][table]
Introduced functions to return time attributes from MATCH_RECOGNIZE
URL: https://github.com/apache/flink/pull/7440#discussion_r248304427
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-11274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16744100#comment-16744100
]
Aljoscha Krettek commented on FLINK-11274:
--
>From looking at the list of changed between 1.7.0
pnowojski commented on a change in pull request #7440: [FLINK-10591][table]
Introduced functions to return time attributes from MATCH_RECOGNIZE
URL: https://github.com/apache/flink/pull/7440#discussion_r248305449
##
File path: docs/dev/table/streaming/match_recognize.md
twalthr commented on a change in pull request #7493: [FLINK-11036] Fix
test_streaming_classloader.sh end-to-end test
URL: https://github.com/apache/flink/pull/7493#discussion_r248307946
##
File path:
twalthr commented on a change in pull request #7493: [FLINK-11036] Fix
test_streaming_classloader.sh end-to-end test
URL: https://github.com/apache/flink/pull/7493#discussion_r248308780
##
File path: flink-end-to-end-tests/test-scripts/test_streaming_classloader.sh
##
@@
[
https://issues.apache.org/jira/browse/FLINK-11159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16744110#comment-16744110
]
vinoyang commented on FLINK-11159:
--
Can we adopt [~Zentol] 's suggestion and give the user an option
twalthr commented on a change in pull request #7493: [FLINK-11036] Fix
test_streaming_classloader.sh end-to-end test
URL: https://github.com/apache/flink/pull/7493#discussion_r248307877
##
File path:
twalthr commented on a change in pull request #7493: [FLINK-11036] Fix
test_streaming_classloader.sh end-to-end test
URL: https://github.com/apache/flink/pull/7493#discussion_r248308081
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-7991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-7991.
---
Resolution: Won't Fix
Fix Version/s: (was: 1.6.4)
(was:
[
https://issues.apache.org/jira/browse/FLINK-11174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-11174.
Resolution: Fixed
> Support unicode for Prometheus label values
>
[
https://issues.apache.org/jira/browse/FLINK-11174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-11174:
-
Summary: Support unicode for Prometheus label values (was: flink Metrics
Prometheus
[
https://issues.apache.org/jira/browse/FLINK-11318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-11318.
Resolution: Not A Problem
Assignee: Kostas Kloudas (was: Aljoscha Krettek)
>
[
https://issues.apache.org/jira/browse/FLINK-11318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reopened FLINK-11318:
--
Assignee: Aljoscha Krettek (was: Kostas Kloudas)
reopen to change resolution
>
aljoscha closed pull request #7460: [FLINK-11187] [s3] Use file over stream for
writes
URL: https://github.com/apache/flink/pull/7460
This is an automated message from the Apache Git Service.
To respond to the message,
[
https://issues.apache.org/jira/browse/FLINK-11169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-11169:
-
Summary: JobManager log is not refreshed in web UI (was: fix the problem
of not being
[
https://issues.apache.org/jira/browse/FLINK-11341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reopened FLINK-11341:
--
> Correct javadoc of AkkaUtils#getAkkaConfig
> --
tillrohrmann commented on a change in pull request #7459: [FLINK-10822] Make
MetricFetcher update interval configurable
URL: https://github.com/apache/flink/pull/7459#discussion_r248283382
##
File path:
tillrohrmann commented on issue #7459: [FLINK-10822] Make MetricFetcher update
interval configurable
URL: https://github.com/apache/flink/pull/7459#issuecomment-454781796
Thanks for the review @zentol, I've addressed your comments.
tillrohrmann commented on issue #6953: [FLINK-10558] [yarn-test] Port
YARNHighAvailabilityITCase to new code…
URL: https://github.com/apache/flink/pull/6953#issuecomment-454787895
Glad to hear. I'll close this PR then and open a new one with my changes. It
would be great if you could take
tillrohrmann closed pull request #6953: [FLINK-10558] [yarn-test] Port
YARNHighAvailabilityITCase to new code…
URL: https://github.com/apache/flink/pull/6953
This is an automated message from the Apache Git Service.
To
Fokko Driesprong created FLINK-11347:
Summary: Optimize the ParquetAvroWriters factory
Key: FLINK-11347
URL: https://issues.apache.org/jira/browse/FLINK-11347
Project: Flink
Issue Type:
azagrebin commented on a change in pull request #7320: [FLINK-11171] Avoid
concurrent usage of StateSnapshotTransformer
URL: https://github.com/apache/flink/pull/7320#discussion_r248305206
##
File path:
StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State
TTL] TTL state incremental cleanup for heap backend
URL: https://github.com/apache/flink/pull/7188#discussion_r248240356
##
File path:
libenchao closed pull request #7492: [FLINK-11311] [datastream] fix
StreamSource implements StreamOperator interface multiple times
URL: https://github.com/apache/flink/pull/7492
This is an automated message from the Apache
[
https://issues.apache.org/jira/browse/FLINK-11219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11219:
---
Labels: pull-request-available (was: )
> Upgrade Jackson dependency to 2.9.6
>
StefanRRichter commented on a change in pull request #7351: [FLINK-11008][State
Backends, Checkpointing]SpeedUp upload state files using multithread
URL: https://github.com/apache/flink/pull/7351#discussion_r248270611
##
File path:
aljoscha closed pull request #7474: [FLINK-11295][configuration] Rename
configuration options of queryable-state from query.x to queryable-state.x
URL: https://github.com/apache/flink/pull/7474
This is an automated message
1 - 100 of 281 matches
Mail list logo
