[
https://issues.apache.org/jira/browse/FLINK-11987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11987:
---
Labels: pull-request-available (was: )
> Kafka producer occasionally throws
Zor-X-L opened a new pull request #8331:
[FLINK-11987][flink-connector-kafka-0.11] convert
NEXT_TRANSACTIONAL_ID_HINT_DESCRIPTOR to a non-static variabl…
URL: https://github.com/apache/flink/pull/8331
…e to avoid StateDescriptor#initializeSerializerUnlessSet throws
NullPointerException
flinkbot commented on issue #8331: [FLINK-11987][flink-connector-kafka-0.11]
convert NEXT_TRANSACTIONAL_ID_HINT_DESCRIPTOR to a non-static variabl…
URL: https://github.com/apache/flink/pull/8331#issuecomment-488582162
Thanks a lot for your contribution to the Apache Flink project. I'm the
StefanRRichter commented on issue #8323: [BP-1.7][FLINK-12296][StateBackend]
Fix local state directory collision with state loss for chained keyed operators
URL: https://github.com/apache/flink/pull/8323#issuecomment-488586209
@klion26 thanks for the backport. Changes look good and the
StefanRRichter merged pull request #8323: [BP-1.7][FLINK-12296][StateBackend]
Fix local state directory collision with state loss for chained keyed operators
URL: https://github.com/apache/flink/pull/8323
This is an
[
https://issues.apache.org/jira/browse/FLINK-12387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-12387.
-
Resolution: Not A Problem
Please give more detailed information about this issue.
> Salesforce
StefanRRichter commented on issue #8323: [BP-1.7][FLINK-12296][StateBackend]
Fix local state directory collision with state loss for chained keyed operators
URL: https://github.com/apache/flink/pull/8323#issuecomment-488586831
@klion26 if we also want to packport for 1.6, it seems like
zentol commented on a change in pull request #8304: [hotfix]Harden
TextInputFormatTest to avoid failure by uncleaned files
URL: https://github.com/apache/flink/pull/8304#discussion_r280325047
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-12389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16831474#comment-16831474
]
Fabian Hueske commented on FLINK-12389:
---
Hi [~yuyang08], thanks for reporting this bug!
Can you
[
https://issues.apache.org/jira/browse/FLINK-12389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16831477#comment-16831477
]
Timo Walther commented on FLINK-12389:
--
[~yuyang08] as far as I can see, you are accessing the
[
https://issues.apache.org/jira/browse/FLINK-12389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-12389:
-
Component/s: (was: Table SQL / Runtime)
Table SQL / Legacy Planner
> flink
zentol commented on issue #8259: [FLINK-12325][metrics] Fix bug in statsd
exporter when using negative values
URL: https://github.com/apache/flink/pull/8259#issuecomment-488590748
hmm, that's unfortunate. Let's use it as a best-effort implementation then.
We can look into adding TCP
[
https://issues.apache.org/jira/browse/FLINK-12305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16831479#comment-16831479
]
Fabian Hueske commented on FLINK-12305:
---
Thanks for reporting this issue [~WizardOfZot].
Proper
Chesnay Schepler created FLINK-12390:
Summary: Fully migrate to asm6
Key: FLINK-12390
URL: https://issues.apache.org/jira/browse/FLINK-12390
Project: Flink
Issue Type: Improvement
Yu Yang created FLINK-12389:
---
Summary: flink codegen set String type for ByteBuffer fields
Key: FLINK-12389
URL: https://issues.apache.org/jira/browse/FLINK-12389
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-12389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16831429#comment-16831429
]
Yu Yang edited comment on FLINK-12389 at 5/2/19 6:30 AM:
-
[~fhue...@gmail.com]
[
https://issues.apache.org/jira/browse/FLINK-12389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16831429#comment-16831429
]
Yu Yang commented on FLINK-12389:
-
[~fhue...@gmail.com] could you share any pointers on how we should
GJL commented on a change in pull request #8233: [FLINK-12227] [runtime]
introduce SchedulingStrategy interface
URL: https://github.com/apache/flink/pull/8233#discussion_r279758565
##
File path:
GJL commented on a change in pull request #8233: [FLINK-12227] [runtime]
introduce SchedulingStrategy interface
URL: https://github.com/apache/flink/pull/8233#discussion_r279787045
##
File path:
GJL commented on a change in pull request #8233: [FLINK-12227] [runtime]
introduce SchedulingStrategy interface
URL: https://github.com/apache/flink/pull/8233#discussion_r280308232
##
File path:
GJL commented on a change in pull request #8233: [FLINK-12227] [runtime]
introduce SchedulingStrategy interface
URL: https://github.com/apache/flink/pull/8233#discussion_r279792342
##
File path:
GJL commented on a change in pull request #8233: [FLINK-12227] [runtime]
introduce SchedulingStrategy interface
URL: https://github.com/apache/flink/pull/8233#discussion_r279787045
##
File path:
zjffdu commented on issue #8144: [FLINK-12159]. Enable YarnMiniCluster
integration test under non-secure mode
URL: https://github.com/apache/flink/pull/8144#issuecomment-488576605
@tillrohrmann I have updated PR (add yarn-site.xml explicitly) , could you
help review it ? Thanks
bowenli86 commented on issue #8329: [FLINK-12239][hive] Support table related
operations in GenericHiveMetastoreCatalog
URL: https://github.com/apache/flink/pull/8329#issuecomment-488562799
Thanks @xuefuz for reviewing! I've addressed the comments.
Would also be great to have
bowenli86 commented on a change in pull request #8329: [FLINK-12239][hive]
Support table related operations in GenericHiveMetastoreCatalog
URL: https://github.com/apache/flink/pull/8329#discussion_r280257423
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-12342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16831427#comment-16831427
]
Zhenqiu Huang commented on FLINK-12342:
---
As using the config and set it to 3000 milliseconds, the
HuangZhenQiu commented on issue #8306: [FLINK-12342] Add fast-heartbeat-delay
yarn config for jobs with large number of containers
URL: https://github.com/apache/flink/pull/8306#issuecomment-488563188
@tillrohrmann @rmetzger
As using the config and set it to 3000 milliseconds, the job
Chesnay Schepler created FLINK-12391:
Summary: Add timeout to transfer.sh
Key: FLINK-12391
URL: https://issues.apache.org/jira/browse/FLINK-12391
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-12260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16831537#comment-16831537
]
Till Rohrmann commented on FLINK-12260:
---
Thanks a lot for your detailed analysis of the ask code
[
https://issues.apache.org/jira/browse/FLINK-12333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-12333.
---
Resolution: Fixed
Fix Version/s: 1.9.0
Fixed via
tillrohrmann closed pull request #8327: [FLINK-12333][docs] Add documentation
for all async operations through REST API
URL: https://github.com/apache/flink/pull/8327
This is an automated message from the Apache Git
tillrohrmann opened a new pull request #8334: [FLINK-12219] Add utility to
check for normal future completion
URL: https://github.com/apache/flink/pull/8334
## What is the purpose of the change
FutureUtils#assertNoException will assert that the given future has not been
completed
tillrohrmann commented on issue #8254: [FLINK-12219][runtime] Yarn application
can't stop when flink job failed in per-job yarn cluste mode
URL: https://github.com/apache/flink/pull/8254#issuecomment-488661029
FYI @lamber-ken I've opened the PR with the utility #8334
lamber-ken commented on issue #8268: [FLINK-12246][runtime] Fix can't get
max_attempts_history_size value when create ExecutionVertex
URL: https://github.com/apache/flink/pull/8268#issuecomment-488663637
Sorry for late for some reason，I can update this pr tomorrow.
tillrohrmann commented on issue #8254: [FLINK-12219][runtime] Yarn application
can't stop when flink job failed in per-job yarn cluste mode
URL: https://github.com/apache/flink/pull/8254#issuecomment-488666980
No, this PR has been closed and should no longer be relevant, right?
rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub]
Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)
URL: https://github.com/apache/flink/pull/6594#discussion_r280451532
##
File path:
rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub]
Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)
URL: https://github.com/apache/flink/pull/6594#discussion_r280450967
##
File path:
rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub]
Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)
URL: https://github.com/apache/flink/pull/6594#discussion_r280449150
##
File path: docs/dev/connectors/pubsub.md
##
@@
tillrohrmann commented on a change in pull request #8318:
[FLINK-12231][runtime] Introduce Scheduler interface and adapt ExecutionGraph
to it
URL: https://github.com/apache/flink/pull/8318#discussion_r280432286
##
File path:
rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub]
Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)
URL: https://github.com/apache/flink/pull/6594#discussion_r280448443
##
File path: docs/dev/connectors/pubsub.md
##
@@
rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub]
Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)
URL: https://github.com/apache/flink/pull/6594#discussion_r280448936
##
File path: docs/dev/connectors/pubsub.md
##
@@
rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub]
Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)
URL: https://github.com/apache/flink/pull/6594#discussion_r280449898
##
File path:
rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub]
Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)
URL: https://github.com/apache/flink/pull/6594#discussion_r280454402
##
File path:
zentol commented on issue #8269: [FLINK-12285][test] Harden savepoint relevant
test cases by explicitly canceling test job
URL: https://github.com/apache/flink/pull/8269#issuecomment-488637332
something like this in `after()` should work:
```
try {
final Deadline deadline =
dawidwys commented on a change in pull request #8214: [FLINK-11476] [table]
Create CatalogManager to manage multiple catalogs and encapsulate Calcite schema
URL: https://github.com/apache/flink/pull/8214#discussion_r280377915
##
File path:
dawidwys commented on a change in pull request #8214: [FLINK-11476] [table]
Create CatalogManager to manage multiple catalogs and encapsulate Calcite schema
URL: https://github.com/apache/flink/pull/8214#discussion_r280379269
##
File path:
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_r280423494
##
File path:
lamber-ken commented on issue #8254: [FLINK-12219][runtime] Yarn application
can't stop when flink job failed in per-job yarn cluste mode
URL: https://github.com/apache/flink/pull/8254#issuecomment-488677963
hi, @tillrohrmann, what this commit
[
https://issues.apache.org/jira/browse/FLINK-12253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-12253:
-
Summary: Setup a class hierarchy for the new logical type system (was:
Setup a class hierarchy
twalthr opened a new pull request #8335: [FLINK-12253][table-common] Setup a
class hierarchy for the new logical type system
URL: https://github.com/apache/flink/pull/8335
## What is the purpose of the change
This PR implements all logical types that Flink's type system should
[
https://issues.apache.org/jira/browse/FLINK-10929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16831530#comment-16831530
]
Stephan Ewen commented on FLINK-10929:
--
[~fan_li_ya]
A lot of this seems applicable for the early
[
https://issues.apache.org/jira/browse/FLINK-12229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16831575#comment-16831575
]
Till Rohrmann commented on FLINK-12229:
---
I think these are valid points [~eaglewatcher]. However,
lamber-ken commented on issue #8254: [FLINK-12219][runtime] Yarn application
can't stop when flink job failed in per-job yarn cluste mode
URL: https://github.com/apache/flink/pull/8254#issuecomment-488668424
right, but when and how to fix this issue when #8334 merged? need to open a
new
flinkbot commented on issue #8335: [FLINK-12253][table-common] Setup a class
hierarchy for the new logical type system
URL: https://github.com/apache/flink/pull/8335#issuecomment-488698361
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the
lamber-ken commented on issue #8254: [FLINK-12219][runtime] Yarn application
can't stop when flink job failed in per-job yarn cluste mode
URL: https://github.com/apache/flink/pull/8254#issuecomment-488702391
hi, @tillrohrmann,
Sorry, it's ok, I just think you just add a future tool
tillrohrmann commented on a change in pull request #8318:
[FLINK-12231][runtime] Introduce Scheduler interface and adapt ExecutionGraph
to it
URL: https://github.com/apache/flink/pull/8318#discussion_r280434680
##
File path:
tillrohrmann commented on a change in pull request #8318:
[FLINK-12231][runtime] Introduce Scheduler interface and adapt ExecutionGraph
to it
URL: https://github.com/apache/flink/pull/8318#discussion_r280438925
##
File path:
tillrohrmann commented on a change in pull request #8318:
[FLINK-12231][runtime] Introduce Scheduler interface and adapt ExecutionGraph
to it
URL: https://github.com/apache/flink/pull/8318#discussion_r280433723
##
File path:
tillrohrmann commented on a change in pull request #8318:
[FLINK-12231][runtime] Introduce Scheduler interface and adapt ExecutionGraph
to it
URL: https://github.com/apache/flink/pull/8318#discussion_r280434081
##
File path:
tillrohrmann commented on a change in pull request #8318:
[FLINK-12231][runtime] Introduce Scheduler interface and adapt ExecutionGraph
to it
URL: https://github.com/apache/flink/pull/8318#discussion_r280432648
##
File path:
tillrohrmann commented on a change in pull request #8318:
[FLINK-12231][runtime] Introduce Scheduler interface and adapt ExecutionGraph
to it
URL: https://github.com/apache/flink/pull/8318#discussion_r280447981
##
File path:
tillrohrmann commented on a change in pull request #8318:
[FLINK-12231][runtime] Introduce Scheduler interface and adapt ExecutionGraph
to it
URL: https://github.com/apache/flink/pull/8318#discussion_r280453988
##
File path:
tillrohrmann commented on a change in pull request #8318:
[FLINK-12231][runtime] Introduce Scheduler interface and adapt ExecutionGraph
to it
URL: https://github.com/apache/flink/pull/8318#discussion_r280453953
##
File path:
tillrohrmann commented on a change in pull request #8318:
[FLINK-12231][runtime] Introduce Scheduler interface and adapt ExecutionGraph
to it
URL: https://github.com/apache/flink/pull/8318#discussion_r280434123
##
File path:
tillrohrmann commented on a change in pull request #8144: [FLINK-12159]. Enable
YarnMiniCluster integration test under non-secure mode
URL: https://github.com/apache/flink/pull/8144#discussion_r280353502
##
File path:
zentol commented on a change in pull request #8259: [FLINK-12325][metrics] Fix
bug in statsd exporter when using negative values
URL: https://github.com/apache/flink/pull/8259#discussion_r280375417
##
File path:
tillrohrmann closed pull request #8313:
[FLINK-12184][Coordination]HistoryServerArchieFetcher incompatible with old
version
URL: https://github.com/apache/flink/pull/8313
This is an automated message from the Apache Git
[
https://issues.apache.org/jira/browse/FLINK-12184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-12184.
---
Resolution: Fixed
Fix Version/s: 1.8.1
1.9.0
zentol commented on a change in pull request #8225: FLINK-10984]Remove
flink-shaded-hadoop from flink
URL: https://github.com/apache/flink/pull/8225#discussion_r280380711
##
File path: pom.xml
##
@@ -53,7 +53,6 @@ under the License.
zentol commented on a change in pull request #8225: FLINK-10984]Remove
flink-shaded-hadoop from flink
URL: https://github.com/apache/flink/pull/8225#discussion_r280388777
##
File path: flink-dist/src/main/assemblies/hadoop.xml
##
@@ -28,13 +28,14 @@ under the License.
zentol commented on a change in pull request #8225: FLINK-10984]Remove
flink-shaded-hadoop from flink
URL: https://github.com/apache/flink/pull/8225#discussion_r280387455
##
File path: flink-dist/src/main/assemblies/hadoop.xml
##
@@ -28,13 +28,14 @@ under the License.
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_r280398656
##
File path:
zjffdu commented on a change in pull request #8144: [FLINK-12159]. Enable
YarnMiniCluster integration test under non-secure mode
URL: https://github.com/apache/flink/pull/8144#discussion_r280412425
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-12359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-12359:
--
Labels: pull-request-available test-stability (was: pull-request-available)
>
[
https://issues.apache.org/jira/browse/FLINK-12359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-12359:
--
Priority: Critical (was: Major)
> SystemResourcesMetricsITCase unstable
>
tillrohrmann commented on a change in pull request #8307:
[FLINK-12359][metrics][tests] Harden SystemResourcesMetricsITCase
URL: https://github.com/apache/flink/pull/8307#discussion_r280423898
##
File path:
tillrohrmann commented on a change in pull request #8307:
[FLINK-12359][metrics][tests] Harden SystemResourcesMetricsITCase
URL: https://github.com/apache/flink/pull/8307#discussion_r280426873
##
File path:
tillrohrmann commented on a change in pull request #8307:
[FLINK-12359][metrics][tests] Harden SystemResourcesMetricsITCase
URL: https://github.com/apache/flink/pull/8307#discussion_r280426992
##
File path:
GJL commented on a change in pull request #8296: [FLINK-12228] [runtime]
Implement Eager Scheduling Strategy
URL: https://github.com/apache/flink/pull/8296#discussion_r279734126
##
File path:
GJL commented on a change in pull request #8296: [FLINK-12228] [runtime]
Implement Eager Scheduling Strategy
URL: https://github.com/apache/flink/pull/8296#discussion_r280334932
##
File path:
GJL commented on a change in pull request #8296: [FLINK-12228] [runtime]
Implement Eager Scheduling Strategy
URL: https://github.com/apache/flink/pull/8296#discussion_r279725973
##
File path:
GJL commented on a change in pull request #8296: [FLINK-12228] [runtime]
Implement Eager Scheduling Strategy
URL: https://github.com/apache/flink/pull/8296#discussion_r280416080
##
File path:
GJL commented on a change in pull request #8296: [FLINK-12228] [runtime]
Implement Eager Scheduling Strategy
URL: https://github.com/apache/flink/pull/8296#discussion_r280423763
##
File path:
GJL commented on a change in pull request #8296: [FLINK-12228] [runtime]
Implement Eager Scheduling Strategy
URL: https://github.com/apache/flink/pull/8296#discussion_r279731809
##
File path:
GJL commented on a change in pull request #8296: [FLINK-12228] [runtime]
Implement Eager Scheduling Strategy
URL: https://github.com/apache/flink/pull/8296#discussion_r279724405
##
File path:
GJL commented on a change in pull request #8296: [FLINK-12228] [runtime]
Implement Eager Scheduling Strategy
URL: https://github.com/apache/flink/pull/8296#discussion_r280319208
##
File path:
GJL commented on a change in pull request #8296: [FLINK-12228] [runtime]
Implement Eager Scheduling Strategy
URL: https://github.com/apache/flink/pull/8296#discussion_r279728912
##
File path:
GJL commented on a change in pull request #8296: [FLINK-12228] [runtime]
Implement Eager Scheduling Strategy
URL: https://github.com/apache/flink/pull/8296#discussion_r280310271
##
File path:
GJL commented on a change in pull request #8296: [FLINK-12228] [runtime]
Implement Eager Scheduling Strategy
URL: https://github.com/apache/flink/pull/8296#discussion_r279729385
##
File path:
GJL commented on a change in pull request #8296: [FLINK-12228] [runtime]
Implement Eager Scheduling Strategy
URL: https://github.com/apache/flink/pull/8296#discussion_r280310078
##
File path:
GJL commented on a change in pull request #8296: [FLINK-12228] [runtime]
Implement Eager Scheduling Strategy
URL: https://github.com/apache/flink/pull/8296#discussion_r279718671
##
File path:
GJL commented on a change in pull request #8296: [FLINK-12228] [runtime]
Implement Eager Scheduling Strategy
URL: https://github.com/apache/flink/pull/8296#discussion_r280430142
##
File path:
GJL commented on a change in pull request #8296: [FLINK-12228] [runtime]
Implement Eager Scheduling Strategy
URL: https://github.com/apache/flink/pull/8296#discussion_r280426220
##
File path:
GJL commented on a change in pull request #8296: [FLINK-12228] [runtime]
Implement Eager Scheduling Strategy
URL: https://github.com/apache/flink/pull/8296#discussion_r279733104
##
File path:
GJL commented on a change in pull request #8296: [FLINK-12228] [runtime]
Implement Eager Scheduling Strategy
URL: https://github.com/apache/flink/pull/8296#discussion_r279729799
##
File path:
GJL commented on a change in pull request #8296: [FLINK-12228] [runtime]
Implement Eager Scheduling Strategy
URL: https://github.com/apache/flink/pull/8296#discussion_r280435403
##
File path:
GJL commented on a change in pull request #8296: [FLINK-12228] [runtime]
Implement Eager Scheduling Strategy
URL: https://github.com/apache/flink/pull/8296#discussion_r280430217
##
File path:
GJL commented on a change in pull request #8296: [FLINK-12228] [runtime]
Implement Eager Scheduling Strategy
URL: https://github.com/apache/flink/pull/8296#discussion_r279718029
##
File path:
GJL commented on a change in pull request #8296: [FLINK-12228] [runtime]
Implement Eager Scheduling Strategy
URL: https://github.com/apache/flink/pull/8296#discussion_r280416137
##
File path:
GJL commented on a change in pull request #8296: [FLINK-12228] [runtime]
Implement Eager Scheduling Strategy
URL: https://github.com/apache/flink/pull/8296#discussion_r279634373
##
File path:
1 - 100 of 197 matches
Mail list logo
