klion26 commented on a change in pull request #7412: [FLINK-10866][Runtime] 1.
Explicitly enable qs server and proxy. 2. QS
URL: https://github.com/apache/flink/pull/7412#discussion_r245463212
##
File path:
flink-core/src/main/java/org/apache/flink/configuration/QueryableStateOptio
klion26 commented on a change in pull request #7412: [FLINK-10866][Runtime] 1.
Explicitly enable qs server and proxy. 2. QS
URL: https://github.com/apache/flink/pull/7412#discussion_r245463422
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManag
yanghua commented on issue #7405: [FLINK-11249] FlinkKafkaProducer011 can not
be migrated to FlinkKafkaProducer
URL: https://github.com/apache/flink/pull/7405#issuecomment-451621417
@pnowojski Can you help me to confirm that this state of migration is
correct? After getting your confirmati
NicoK commented on issue #7348: [FLINK-11207][core] update commons-compress to
1.18
URL: https://github.com/apache/flink/pull/7348#issuecomment-451603867
Done - except for
`flink-shaded-hadoop/flink-shaded-hadoop2/src/main/resources/META-INF/NOTICE`
which did not contain any reference to
tillrohrmann commented on a change in pull request #7320: [FLINK-11171] Avoid
concurrent usage of StateSnapshotTransformer
URL: https://github.com/apache/flink/pull/7320#discussion_r245370394
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/state/StateSnapshotTran
tillrohrmann commented on a change in pull request #7320: [FLINK-11171] Avoid
concurrent usage of StateSnapshotTransformer
URL: https://github.com/apache/flink/pull/7320#discussion_r245358031
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapKeyedSta
tillrohrmann commented on a change in pull request #7320: [FLINK-11171] Avoid
concurrent usage of StateSnapshotTransformer
URL: https://github.com/apache/flink/pull/7320#discussion_r245370513
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/state/StateSnapshotTran
[
https://issues.apache.org/jira/browse/FLINK-11088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-11088:
--
Issue Type: Sub-task (was: Improvement)
Parent: FLINK-11271
> Improve Kerberos Authentication
tillrohrmann commented on a change in pull request #7320: [FLINK-11171] Avoid
concurrent usage of StateSnapshotTransformer
URL: https://github.com/apache/flink/pull/7320#discussion_r245368875
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/CopyOnWriteS
tillrohrmann commented on a change in pull request #7320: [FLINK-11171] Avoid
concurrent usage of StateSnapshotTransformer
URL: https://github.com/apache/flink/pull/7320#discussion_r245362372
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/state/RegisteredKeyValu
[
https://issues.apache.org/jira/browse/FLINK-11088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-11088:
--
Summary: Improve Kerberos Authentication Keytab discovery on YARN (was:
Improve Kerberos Authenticati
Rong Rong created FLINK-11271:
-
Summary: Improve Kerberos Credential Distribution
Key: FLINK-11271
URL: https://issues.apache.org/jira/browse/FLINK-11271
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-10848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16734322#comment-16734322
]
Shuyi Chen commented on FLINK-10848:
Fixed in master: e26d90fc86b266978b4bac84fe02ca
suez1224 commented on issue #7078: [FLINK-10848][YARN] properly remove YARN
ContainerRequest upon container allocation success
URL: https://github.com/apache/flink/pull/7078#issuecomment-451497384
Thanks a lot for all the reviews. We've tested the branch in production for
some time, mergin
asfgit closed pull request #7078: [FLINK-10848][YARN] properly remove YARN
ContainerRequest upon container allocation success
URL: https://github.com/apache/flink/pull/7078
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
tillrohrmann commented on a change in pull request #7277: [FLINK-11022] Add
LICENSE & NOTICE files for 1.6
URL: https://github.com/apache/flink/pull/7277#discussion_r245327116
##
File path:
flink-filesystems/flink-s3-fs-presto/src/main/resources/META-INF/NOTICE
##
@@ -1,8
tillrohrmann commented on a change in pull request #7277: [FLINK-11022] Add
LICENSE & NOTICE files for 1.6
URL: https://github.com/apache/flink/pull/7277#discussion_r245337952
##
File path: NOTICE-binary
##
@@ -0,0 +1,4297 @@
+// ---
[
https://issues.apache.org/jira/browse/FLINK-2597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-2597:
--
Labels: pull-request-available (was: )
> Add a test for Avro-serialized Kafka messages
>
rmetzger closed pull request #2705: [FLINK-2597][FLINK-4050] Add wrappers for
Kafka serializers, test for partitioner and documentation
URL: https://github.com/apache/flink/pull/2705
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed
hequn8128 commented on issue #7271: [FLINK-11124][table] Add private[flink] to
TemporalTableFunction.create() method
URL: https://github.com/apache/flink/pull/7271#issuecomment-451475041
@twalthr Thanks a lot for the review and merge.
--
[
https://issues.apache.org/jira/browse/FLINK-11124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-11124.
Resolution: Fixed
Fix Version/s: 1.8.0
Fixed in master: b82b24d720bdebd58ba507af98e68ab0277
asfgit closed pull request #7271: [FLINK-11124][table] Add private[flink] to
TemporalTableFunction.create() method
URL: https://github.com/apache/flink/pull/7271
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
[
https://issues.apache.org/jira/browse/FLINK-11001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16734222#comment-16734222
]
Timo Walther commented on FLINK-11001:
--
Updated exception message in master: 038dc0
twalthr commented on a change in pull request #7271: [FLINK-11124][table] Add
private[flink] to TemporalTableFunction.create() method
URL: https://github.com/apache/flink/pull/7271#discussion_r245321721
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table
twalthr commented on a change in pull request #7271: [FLINK-11124][table] Add
private[flink] to TemporalTableFunction.create() method
URL: https://github.com/apache/flink/pull/7271#discussion_r245321721
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table
twalthr closed pull request #7289: [FLINK-11001][table] Fix window rowtime
attribute can't be renamed bug in Java
URL: https://github.com/apache/flink/pull/7289
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
twalthr commented on issue #7289: [FLINK-11001][table] Fix window rowtime
attribute can't be renamed bug in Java
URL: https://github.com/apache/flink/pull/7289#issuecomment-451459198
@hequn8128 thanks for mentioning the
`StreamTableEnvironmentValidationTest.testInvalidAliasWithProctimeAttr
[
https://issues.apache.org/jira/browse/FLINK-11173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-11173.
Resolution: Fixed
Fix Version/s: 1.8.0
1.7.2
1.6.4
Fi
asfgit closed pull request #7374: [FLINK-11173][table] Fix the exception
message of proctime attribute validation in TableSourceUtil#validateTableSource
URL: https://github.com/apache/flink/pull/7374
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge,
[
https://issues.apache.org/jira/browse/FLINK-11227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-11227.
Resolution: Fixed
Fix Version/s: (was: 1.6.4)
Fixed in master: 1c3c663ba7d55fcd33af1502
[
https://issues.apache.org/jira/browse/FLINK-11227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-11227:
-
Affects Version/s: (was: 1.6.3)
> The DescriptorProperties contains some bounds checking err
asfgit closed pull request #7373: [FLINK-11227] [table] The
DescriptorProperties contains some bounds checking errors
URL: https://github.com/apache/flink/pull/7373
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake
[
https://issues.apache.org/jira/browse/FLINK-11268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11268:
---
Labels: pull-request-available (was: )
> Update deploy_staging_jars.sh to deploy multiple f
zentol opened a new pull request #7417: [FLINK-11268][elease] Deploy multiple
flink-shaded-hadoop2 artifacts
URL: https://github.com/apache/flink/pull/7417
## What is the purpose of the change
This PR modifies the release scripts to deploy multiple
`flink-shaded-hadoop2` artifacts,
[
https://issues.apache.org/jira/browse/FLINK-9?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-9.
Resolution: Fixed
Fix Version/s: 1.8.0
1.7.2
1.6.4
Fi
asfgit closed pull request #7379: [FLINK-9][docs] Correct Scala example for
Table Function in User-…
URL: https://github.com/apache/flink/pull/7379
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-11267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11267:
---
Labels: pull-request-available (was: )
> Update create_binary_release.sh to not create hado
zentol opened a new pull request #7416: [FLINK-11267][release] Only create
hadoop-free binary by default
URL: https://github.com/apache/flink/pull/7416
## What is the purpose of the change
With this PR the `create_binary_release` script only creates hadoop-free
Flink by default. Thi
leesf opened a new pull request #7415: [hotfix][docs] fix typo in
addShutdownHookThread Javadoc
URL: https://github.com/apache/flink/pull/7415
## What is the purpose of the change
Fix typo in ShutdownHookUtil#addShutdownHookThread Javadoc
## Brief change log
Fix typ
dawidwys closed pull request #7380: [hotfix][docs] Fix incorrect example in cep
doc
URL: https://github.com/apache/flink/pull/7380
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:
As this is a fore
Chesnay Schepler created FLINK-11270:
Summary: Do not include hadoop in flink-dist by default
Key: FLINK-11270
URL: https://issues.apache.org/jira/browse/FLINK-11270
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-11026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-11026.
Resolution: Fixed
Release Note:
The naming scheme for kafka/elasticsearch6 sql-jars
[
https://issues.apache.org/jira/browse/FLINK-11026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reopened FLINK-11026:
--
> Rework creation of sql-client connector/format jars
> --
asfgit closed pull request #7388: [hotfix][javadocs][table] Fix typos in
JavaDocs for Table API
URL: https://github.com/apache/flink/pull/7388
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:
As t
[
https://issues.apache.org/jira/browse/FLINK-11026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-11026.
Resolution: Fixed
Fix Version/s: 1.8.0
master: b6237688b27ee2ca2cdda49820c5d2d541e1
Chesnay Schepler created FLINK-11268:
Summary: Update deploy_staging_jars.sh to deploy multiple
flink-shaded-hadoop2 versions
Key: FLINK-11268
URL: https://issues.apache.org/jira/browse/FLINK-11268
[
https://issues.apache.org/jira/browse/FLINK-11026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reopened FLINK-11026:
--
> Rework creation of sql-client connector/format jars
> --
[
https://issues.apache.org/jira/browse/FLINK-11026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16734042#comment-16734042
]
Chesnay Schepler edited comment on FLINK-11026 at 1/4/19 11:11 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-11026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-11026.
Resolution: Fixed
> Rework creation of sql-client connector/format jars
>
zentol closed pull request #7341: [FLINK-11026][kafka][SQL] Rework kafka
sql-client jar creation
URL: https://github.com/apache/flink/pull/7341
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:
As
[
https://issues.apache.org/jira/browse/FLINK-11234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-11234.
Resolution: Fixed
Fix Version/s: 1.7.2
1.6.4
Fixed in master: 04035ce8b7
Chesnay Schepler created FLINK-11269:
Summary: Extend Download page to list optional components
Key: FLINK-11269
URL: https://issues.apache.org/jira/browse/FLINK-11269
Project: Flink
Issu
Chesnay Schepler created FLINK-11267:
Summary: Update create_binary_release.sh to not create
hadoop-specific releases
Key: FLINK-11267
URL: https://issues.apache.org/jira/browse/FLINK-11267
Projec
Chesnay Schepler created FLINK-11266:
Summary: Only release hadoop-free Flink
Key: FLINK-11266
URL: https://issues.apache.org/jira/browse/FLINK-11266
Project: Flink
Issue Type: Improvemen
KarmaGYZ commented on a change in pull request #7402: [hotfix][docs] Fulfill
some empty description in Config Doc
URL: https://github.com/apache/flink/pull/7402#discussion_r245267301
##
File path:
flink-core/src/main/java/org/apache/flink/configuration/WebOptions.java
##
[
https://issues.apache.org/jira/browse/FLINK-11253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11253:
---
Labels: pull-request-available (was: )
> Incorrect way to stop yarn session described in ya
KarmaGYZ commented on a change in pull request #7402: [hotfix][docs] Fulfill
some empty description in Config Doc
URL: https://github.com/apache/flink/pull/7402#discussion_r245267301
##
File path:
flink-core/src/main/java/org/apache/flink/configuration/WebOptions.java
##
[
https://issues.apache.org/jira/browse/FLINK-11252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-11252:
-
Summary: Add Scala 2.12 download column (was: Download page contains
irrelevant "Scala
asfgit closed pull request #7386: [FLINK-11234][table][tests] fix
ExternalTableCatalogBuilder::supportsBatch
URL: https://github.com/apache/flink/pull/7386
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 prove
[
https://issues.apache.org/jira/browse/FLINK-11253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16734024#comment-16734024
]
Tao Yang commented on FLINK-11253:
--
Thanks [~zjffdu] and [~till.rohrmann] for your sugg
[
https://issues.apache.org/jira/browse/FLINK-11252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-11252.
Resolution: Fixed
asf-site: e7ece77db1621c1b993932b53803fa69b3f8629d
> Add Scala 2.12 dow
yt526 opened a new pull request #7414: [FLINK-11253] Add shutdown hook for yarn
session client in attached mode
URL: https://github.com/apache/flink/pull/7414
## What is the purpose of the change
This pull request makes yarn session cluster shutdown through adding
shutdown h
pnowojski commented on issue #7405: [FLINK-11249] FlinkKafkaProducer011 can not
be migrated to FlinkKafkaProducer
URL: https://github.com/apache/flink/pull/7405#issuecomment-451407399
Good point @zentol. It looks like kafka producer migrations tests are
missing and only kafka consumer has
[
https://issues.apache.org/jira/browse/FLINK-11265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11265:
---
Labels: pull-request-available (was: )
> Invalid reference to AvroSinkWriter in example Avr
Fokko opened a new pull request #7413: [FLINK-11265][docs] AvroSinkWriter →
AvroKeyValueSinkWriter
URL: https://github.com/apache/flink/pull/7413
AvroSinkWriter should be AvroKeyValueSinkWriter
This is an automated message fr
Fokko Driesprong created FLINK-11265:
Summary: Invalid reference to AvroSinkWriter in example
AvroKeyValueSinkWriter
Key: FLINK-11265
URL: https://issues.apache.org/jira/browse/FLINK-11265
Project
zentol commented on a change in pull request #7402: [hotfix][docs] Fulfill some
empty description in Config Doc
URL: https://github.com/apache/flink/pull/7402#discussion_r245254995
##
File path:
flink-core/src/main/java/org/apache/flink/configuration/WebOptions.java
##
@@
tillrohrmann commented on a change in pull request #7346: [FLINK-11134][rest]
Do not log stacktrace handled exceptions
URL: https://github.com/apache/flink/pull/7346#discussion_r245252896
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/AbstractHandle
zentol commented on issue #7405: [FLINK-11249] FlinkKafkaProducer011 can not be
migrated to FlinkKafkaProducer
URL: https://github.com/apache/flink/pull/7405#issuecomment-451398602
@pnowojski Do we have a migration test for the kafka producers(i.e. from 1.7
-> 1.8)? I'm curious since travi
[
https://issues.apache.org/jira/browse/FLINK-11244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-11244.
Resolution: Not A Problem
> flink web.port can not be configured correctly in yarn mode
>
[
https://issues.apache.org/jira/browse/FLINK-11244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reopened FLINK-11244:
--
> flink web.port can not be configured correctly in yarn mode
> --
zentol closed pull request #7411: [hotfix][docs] Fix typos
URL: https://github.com/apache/flink/pull/7411
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:
As this is a foreign pull request (from a f
[
https://issues.apache.org/jira/browse/FLINK-10866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10866:
---
Labels: pull-request-available (was: )
> Queryable state can prevent cluster from starting
eaglewatcherwb opened a new pull request #7412: [FLINK-10866][Runtime] 1.
Explicitly enable qs server and proxy. 2. QS
URL: https://github.com/apache/flink/pull/7412
startup failure not block TM startup
Change-Id: Id79c8bf97002a387a80be563a43dce3210143dc2
## What is th
wangzzu opened a new pull request #7411: [hotfix][docs] Fix typos
URL: https://github.com/apache/flink/pull/7411
## What is the purpose of the change
Fix typos
## Brief change log
Fix typos
## Verifying this change
This change is a trivial rework /
shuiqiangchen opened a new pull request #7410: [Flink 11264] Fail to start
scala shell
URL: https://github.com/apache/flink/pull/7410
## What is the purpose of the change
fix the problem of Fail to start scala shell when outside the bin directory.
## Brief change l
76 matches
Mail list logo
