GitHub user zjureel opened a pull request:
https://github.com/apache/flink/pull/5209
[FLINK-7711] Port JarListHandler to WebMonitorEndpoint
## What is the purpose of the change
Port JarListHandler to WebMonitorEndpoint
## Brief change log
- *Create
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/3915
@tzulitai I notice that there's some update of this issue, so rebase master
to this PR, could you please take a look when you're free, thanks
---
GitHub user zjureel opened a pull request:
https://github.com/apache/flink/pull/5149
[FLINK-7858][flp6] Port JobVertexTaskManagersHandler to REST endpoint
## What is the purpose of the change
Port JobVertexTaskManagersHandler to REST endpoint
## Brief change log
GitHub user zjureel opened a pull request:
https://github.com/apache/flink/pull/5035
[FLINK-7857][flp6] Port JobVertexDetails to REST endpoint
## What is the purpose of the change
Port JobVertexDetails to REST endpoint
## Brief change log
- *Add
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4893
@tillrohrmann Thank you for your review, I have fixed the problems of this
PR, thanks
---
Github user zjureel closed the pull request at:
https://github.com/apache/flink/pull/4524
---
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4893
@tillrohrmann Thank you for you suggestions, and I think move these things
to the `JobMaster` would be good. I think this issue could be fixed as follows:
1. Add `CompletableFuture
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4930
@zentol Thank you for your remind, I'v updated jackson imports. thanks
---
GitHub user zjureel reopened a pull request:
https://github.com/apache/flink/pull/4930
[FLINK-7941][flip6] Port SubtasksTimesHandler to new REST endpoint
## What is the purpose of the change
Port SubtasksTimesHandler to new REST endpoint
## Brief change log
Github user zjureel closed the pull request at:
https://github.com/apache/flink/pull/4930
---
Github user zjureel closed the pull request at:
https://github.com/apache/flink/pull/4307
---
GitHub user zjureel opened a pull request:
https://github.com/apache/flink/pull/4930
[FLINK-7941][flip6] Port SubtasksTimesHandler to new REST endpoint
## What is the purpose of the change
Port SubtasksTimesHandler to new REST endpoint
## Brief change log
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4884
Hi @tillrohrmann , could you merge this PR when you're free? Some issues
depend on `MetricFetcher` and I found it would be added to
`DispatcherRestEndpoint` in this PR. THX
---
GitHub user zjureel opened a pull request:
https://github.com/apache/flink/pull/4893
[FLINK-7856][flip6] Port JobVertexBackPressureHandler to REST endpoint
## What is the purpose of the change
Port JobVertexBackPressureHandler to REST endpoint
## Brief change log
Github user zjureel closed the pull request at:
https://github.com/apache/flink/pull/4455
---
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4455
@zentol Thank you for your reply, and I agree with you that the risk will
be a little high for this PR. I'd like to close this PR if there's no better
solution, thanks
---
Github user zjureel closed the pull request at:
https://github.com/apache/flink/pull/4843
---
GitHub user zjureel opened a pull request:
https://github.com/apache/flink/pull/4857
[FLINK-7855] Port JobVertexAccumulatorsHandler to REST endpoint
## What is the purpose of the change
Port JobVertexAccumulatorsHandler to REST endpoint
## Brief change log
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4843
@zentol Thank you for your review. I think you're right about
ExecutionExceptionsInfo and JobExceptionsInfo, and I have fixed them already.
THX
---
GitHub user zjureel opened a pull request:
https://github.com/apache/flink/pull/4843
[FLINK-7703] Port JobExceptionsHandler to new REST endpoint
## What is the purpose of the change
Port JobExceptionsHandler to new REST endpoint
## Brief change log
- *Create
Github user zjureel commented on a diff in the pull request:
https://github.com/apache/flink/pull/4574#discussion_r141804405
--- Diff: docs/dev/types_serialization.md ---
@@ -115,6 +115,8 @@ conditions are fulfilled:
or have a public getter- and a setter- method that follows
Github user zjureel closed the pull request at:
https://github.com/apache/flink/pull/4654
---
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4675
@rmetzger @tzulitai I create this PR and try to fix
[https://issues.apache.org/jira/browse/FLINK-7386(https://issues.apache.org/jira/browse/FLINK-7386).
In the PR I do some things as follows
GitHub user zjureel opened a pull request:
https://github.com/apache/flink/pull/4675
[FLINK-7386] FIx Elasticsearch 5 connector is not compatible with
Elasticsearch 5.2+ client
## What is the purpose of the change
Add flink-connector-elasticsearch5.3 to support
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4654
@kl0u @zentol Thank you for your suggestions. So remove the code
`.addLast(new HttpObjectAggregator(100*1024*1024)` will be a temporary fix?
In fact it surprises me that the client sends
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4654
@kl0u I have tried to fix
[https://issues.apache.org/jira/browse/FLINK-7521](https://issues.apache.org/jira/browse/FLINK-7521)
in this PR, could you please have a look when you're free, thanks
---
GitHub user zjureel opened a pull request:
https://github.com/apache/flink/pull/4654
[FLINK-7521] Add config option to set the content length limit of REST
server and client
## Brief change log
Add config option to set the content length limit of REST server and client
Github user zjureel closed the pull request at:
https://github.com/apache/flink/pull/4500
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4500
Thank you for your merge @aljoscha
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4574
@ggevay @greghogan Thank you for your suggestions, I tried to add some
notice about performance loss in the log, what do you think? Thanks
---
If your project is set up for it, you can reply
GitHub user zjureel opened a pull request:
https://github.com/apache/flink/pull/4621
[FLINK-7495] Call to AbstractUdfStreamOperator#initializeState() in the
beginning
## What is the purpose of the change
Call to AbstractUdfStreamOperator#initializeState() in the beginning
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4562
@NicoK Great, tt's too useful for me, thank you very much!
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4562
@NicoK Than you for your review, I have reverted the imports changed by
IDE, thanks
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well
Github user zjureel commented on a diff in the pull request:
https://github.com/apache/flink/pull/4562#discussion_r134704354
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyMessage.java
---
@@ -220,9 +220,7 @@ void releaseBuffer
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4574
@tzulitai I create this PR to fix
[https://issues.apache.org/jira/browse/FLINK-6864](https://issues.apache.org/jira/browse/FLINK-6864),
I think add logs instead of removing them will be better, what
GitHub user zjureel opened a pull request:
https://github.com/apache/flink/pull/4574
[FLINK-6864] Fix confusing "invalid POJO type" messages from TypeExtractor
## What is the purpose of the change
Fix confusing "invalid POJO type" message
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4562
@tedyu @NicoK Than you for your suggestions, it sounds good to me, thanks
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your
GitHub user zjureel opened a pull request:
https://github.com/apache/flink/pull/4562
[FLINK-7402] Fix ineffective null check in NettyMessage#write()
## What is the purpose of the change
Fix ineffective null check in NettyMessage#write()
## Brief change log
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4476
@tillrohrmann @aljoscha I have fixed
[https://issues.apache.org/jira/browse/FLINK-7307](https://issues.apache.org/jira/browse/FLINK-7307)
in this PR, could you please have a look when you're free
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4524
@zentol Thank you for your review, I have rename the pattern, thanks
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project
Github user zjureel closed the pull request at:
https://github.com/apache/flink/pull/4511
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4511
Thank you for merging it
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes
GitHub user zjureel opened a pull request:
https://github.com/apache/flink/pull/4524
[FLINK-7419] Shade jackson dependency in flink-avro
## What is the purpose of the change
Shade jackson dependency in flink-avro to avoid incompatible versions
## Brief change log
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4511
@aljoscha Sorry it's my fault, I have fixed it, thanks :)
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4511
@aljoscha What do you think of this change for
[https://issues.apache.org/jira/browse/FLINK-7396](https://issues.apache.org/jira/browse/FLINK-7396)
Thanks
---
If your project is set up
GitHub user zjureel opened a pull request:
https://github.com/apache/flink/pull/4511
[FLINK-7396] Don't put multiple directories in HADOOP_CONF_DIR in config.sh
## What is the purpose of the change
Fix put multiple directories in HADOOP_CONF_DIR in config.sh
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4500
@zentol I have created this PR to fix
[https://issues.apache.org/jira/browse/FLINK-6787](https://issues.apache.org/jira/browse/FLINK-6787),
could you please have a look when you're free, thanks
GitHub user zjureel opened a pull request:
https://github.com/apache/flink/pull/4500
[FLINK-6787] Fix Job-/StoppingException extend FlinkException
## What is the purpose of the change
Fix Job-/StoppingException extend FlinkException
## Brief change log
GitHub user zjureel opened a pull request:
https://github.com/apache/flink/pull/4476
[FLINK-7307] Add proper command line parsing tool to ClusterEntrypoint
## What is the purpose of the change
Add a proper command line parsing tool `CommandLineParser` to the entry
point
Github user zjureel closed the pull request at:
https://github.com/apache/flink/pull/4475
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4475
@tillrohrmann I create `CommandLineParser` instead of `ParameterTool` in
`ClusterEntrypoint#parseArguments`, please have a look when you're free, thanks
---
If your project is set up for it, you
GitHub user zjureel opened a pull request:
https://github.com/apache/flink/pull/4475
[FLINK-7251] Add proper command line parsing tool to ClusterEntrypoint
## What is the purpose of the change
Add a proper command line parsing tool `CommandLineParser` to the entry
point
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4455
1. For the `StateBackendITCase`, it can be resolved by bumping the tycho
compiler version to 1.0.0, but when I try to use tycho compiler version 1.0.0
in `flink-java`, it will cause lambda exception
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4455
Maybe it's better to move *ITCase to `Flink-java` project and rename them
to *Test, I find it will be alright, what do you think? @zentol
---
If your project is set up for it, you can reply
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4455
The `JobRetrievalITCase` is ok when I remove the tycho-compiler completely,
I think it may be a bug of the tycho-compiler :(
---
If your project is set up for it, you can reply to this email
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4455
@zentol Thank you for your suggestion, it sounds good to me and I have
fixed them, thanks
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub
GitHub user zjureel opened a pull request:
https://github.com/apache/flink/pull/4455
[FLINK-7251] Merge the flink-java8 project into corresponding flink project
## What is the purpose of the change
Merge the codes in flink-java8 project into corresponding flink project
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4075
@zentol I updated this PR and fix some code conflicts, could you please
have a look when you're free, thanks
---
If your project is set up for it, you can reply to this email and have your
reply
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4376
I found the following kinda stuff from CI, and it seems not relevant to
this issue, what do you think? @tillrohrmann
```
Running
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4415
@tillrohrmann Great, use `loadConfigurationWithDynamicProperties` instead
of `loadConfiguration` and `setDynamicProperties` will be more concise, it
sounds good to me, thanks
---
If your project
Github user zjureel closed the pull request at:
https://github.com/apache/flink/pull/4292
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4415
@tillrohrmann Thank you for your suggestion, I have update the PR template
and add test caseï¼ thanks
---
If your project is set up for it, you can reply to this email and have your
reply appear
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4415
@tillrohrmann @aljoscha I create this PR and try to fix
[https://issues.apache.org/jira/browse/FLINK-7269](https://issues.apache.org/jira/browse/FLINK-7269),
could you please have look when you're
GitHub user zjureel opened a pull request:
https://github.com/apache/flink/pull/4415
[FLINK-7269] Refactor passing of dynamic properties
*Thank you very much for contributing to Apache Flink - we are happy that
you want to help us improve Flink. To help the community review your
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4277
Thank you for your merging, thanks
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled
Github user zjureel closed the pull request at:
https://github.com/apache/flink/pull/4277
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
Github user zjureel closed the pull request at:
https://github.com/apache/flink/pull/4220
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4220
@StephanEwen Thank you for your merging :)
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
GitHub user zjureel opened a pull request:
https://github.com/apache/flink/pull/4376
[FLINK-6521] Add per job cleanup methods to HighAvailabilityServices
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/3915
@tzulitai No problem, thank you for your attension :)
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4361
@tzulitai Thank you for your reply. I found there's no such problem for
Kafka 08, and I have already fix this for 09 too. Thanks
---
If your project is set up for it, you can reply to this email
GitHub user zjureel opened a pull request:
https://github.com/apache/flink/pull/4361
[FLINK-7222] fix Kafka010ITCase fails on windows
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If your
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4292
@zentol What do you think of @StephanEwen 's suggestion? I think this
change does cause some incompatibilities for user, thanks
---
If your project is set up for it, you can reply to this email
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4277
Thank you for your reply, I will fix
[FLINK-6665](https://issues.apache.org/jira/browse/FLINK-6665) after this PR is
merged, thanks :)
---
If your project is set up for it, you can reply
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4307
@zentol Thank you for your review, I have fix the problems you metioned as
follows:
1. rename `TaskExecutorMetricsInitializer` to `MetricUtils`
2. move `taskManagerMetricGroup.close()` from
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4307
@zentol @aljoscha I have tried to fix this issue, please have a look when
you are free, thanks
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub
GitHub user zjureel opened a pull request:
https://github.com/apache/flink/pull/4307
[FLINK-7100] TaskManager metrics are registered twice
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/3921
Thank you for merging it @aljoscha
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled
Github user zjureel closed the pull request at:
https://github.com/apache/flink/pull/3921
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
Github user zjureel commented on a diff in the pull request:
https://github.com/apache/flink/pull/4278#discussion_r126383468
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/BootstrapTools.java
---
@@ -185,8 +185,8 @@ public static WebMonitor
GitHub user zjureel opened a pull request:
https://github.com/apache/flink/pull/4292
[FLINK-6588] Rename NumberOfFullRestarts metric
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If your
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/3921
I have fixed it, thanks @aljoscha
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled
Github user zjureel commented on a diff in the pull request:
https://github.com/apache/flink/pull/4278#discussion_r126366568
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/BootstrapTools.java
---
@@ -185,8 +185,8 @@ public static WebMonitor
Github user zjureel commented on a diff in the pull request:
https://github.com/apache/flink/pull/4278#discussion_r126343858
--- Diff:
flink-contrib/flink-storm/src/main/java/org/apache/flink/storm/api/FlinkSubmitter.java
---
@@ -91,12 +91,11 @@ public static void submitTopology
GitHub user zjureel opened a pull request:
https://github.com/apache/flink/pull/4278
[FLINK-7099] Replace usages of deprecated JOB_MANAGER_IPC_PORT_KEY and
JOB_MANAGER_IPC_ADDRESS_KEY
â¦d JOB_MANAGER_IPC_ADDRESS_KEY
Thanks for contributing to Apache Flink. Before you open
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/3921
I have updated the code according to your suggestion, please have a look
when you are free, thanks :)
---
If your project is set up for it, you can reply to this email and have your
reply appear
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4277
@StephanEwen @tillrohrmann As discussed in
https://github.com/apache/flink/pull/4220, I create this PR to fix issue
[FLINK-6667](https://issues.apache.org/jira/browse/FLINK-6667). Could you
please
GitHub user zjureel opened a pull request:
https://github.com/apache/flink/pull/4277
[FLINK-6667] Pass a callback type to the RestartStrategy, rather than the
full ExecutionGraph
⦠the full ExecutionGraph
Thanks for contributing to Apache Flink. Before you open your pull
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/3921
@aljoscha Sorry for replying late, your suggestion sounds good to me. In
fact, I was hesitating to add `getDefaultParallelism()` in `ContextEnvironment`
and `ClusterClient` for there have been
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4220
@StephanEwen Thank you for your suggestion, I think you raise an important
problem about this issue. I agree with you, I will pick
[FLINK-6667](https://issues.apache.org/jira/browse/FLINK-6667
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4204
@tillrohrmann Thank you for your review. I use `prefix` as the name of sub
directory, and add test case to
`FileSystemStateStorageHelper#closeAndCleanupAllData`. Also I have fixed the
problem you
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4173
@tzulitai Thank you for merging this :)
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
Github user zjureel closed the pull request at:
https://github.com/apache/flink/pull/4184
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4184
@aljoscha Thank you for merging it, I will close it, thanks :)
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4220
@tillrohrmann Thank you for your review, I have remove
`restart(ExecutionGraph executionGraph)`, and use `ScheduledExecutor` instead
of `ScheduledExecutorService` you metioned. Thanks
---
If your
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/3915
@tzulitai Thank you for your suggestion. I think move the conversion
between date and offset to `KafkaConsumerThread` is really a good idea. I have
fixed the NPE in test case, and move
Github user zjureel commented on a diff in the pull request:
https://github.com/apache/flink/pull/3915#discussion_r124977924
--- Diff:
flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer010.java
---
@@ -128,6
GitHub user zjureel opened a pull request:
https://github.com/apache/flink/pull/4220
[FLINK-6665] Pass a ScheduledExecutorService to the RestartStrategy
⦠avoid any sleeps.
Thanks for contributing to Apache Flink. Before you open your pull request,
please take
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4075
@zentol Thank you for your suggestion, I have fixed the problems you
metioned. Thanks
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4204
Hi @tillrohrmann , I have created this PR for issue
[FLINK-6522.](https://issues.apache.org/jira/browse/FLINK-6522) Could you
please have a look when you're free, thanks
---
If your project is set
1 - 100 of 146 matches
Mail list logo
