Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3258
---
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 is enab
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3254
---
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 is enab
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/3272
Thanks @uce and @NicoK. I incorporated your suggestions and will merge now.
---
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 pr
Github user aljoscha closed the pull request at:
https://github.com/apache/flink/pull/3272
---
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 is en
[
https://issues.apache.org/jira/browse/FLINK-5721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854297#comment-15854297
]
ASF GitHub Bot commented on FLINK-5721:
---
Github user aljoscha commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-5721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854298#comment-15854298
]
ASF GitHub Bot commented on FLINK-5721:
---
Github user aljoscha closed the pull reques
[
https://issues.apache.org/jira/browse/FLINK-5721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-5721.
---
Resolution: Fixed
Fix Version/s: 1.2.1
1.3.0
Added on release-1.2 in
[
https://issues.apache.org/jira/browse/FLINK-5717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854309#comment-15854309
]
Aljoscha Krettek commented on FLINK-5717:
-
Then the fix should probably also be th
[
https://issues.apache.org/jira/browse/FLINK-5662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854313#comment-15854313
]
ASF GitHub Bot commented on FLINK-5662:
---
GitHub user twalthr opened a pull request:
GitHub user twalthr opened a pull request:
https://github.com/apache/flink/pull/3277
[FLINK-5662] [table] Rework internal type handling of Table API
This PR refactors the internal type handling of the Table API. It...
- converts type to internal Row type immediately in Batch
[
https://issues.apache.org/jira/browse/FLINK-5717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-5717:
Affects Version/s: (was: 2.0.0)
1.2.0
> NPE on SessionWindows wit
[
https://issues.apache.org/jira/browse/FLINK-2883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-2883:
--
Fix Version/s: 1.2.1
1.3.0
> Add documentation to forbid key-modifying ReduceFunction
[
https://issues.apache.org/jira/browse/FLINK-5717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854333#comment-15854333
]
Oriol Orellana commented on FLINK-5717:
---
Yes, the fix is the same.
> NPE on Session
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/3277
I forgot to test TableSinks. I will do this tomorrow.
---
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 thi
GitHub user tzulitai opened a pull request:
https://github.com/apache/flink/pull/3278
[FLINK-5701] [kafka] FlinkKafkaProducer should check asyncException on
checkpoints
Prior to this change, at-least-once is violated for the FlinkKafkaProducer
because we were not failing checkpoint
[
https://issues.apache.org/jira/browse/FLINK-5701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854349#comment-15854349
]
ASF GitHub Bot commented on FLINK-5701:
---
GitHub user tzulitai opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-5662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854347#comment-15854347
]
ASF GitHub Bot commented on FLINK-5662:
---
Github user twalthr commented on the issue:
GitHub user NicoK opened a pull request:
https://github.com/apache/flink/pull/3279
[FLINK-5618][docs] createSerializer must actually get a non-null
ExecutionConfig
providing `null` fails with a NPE
You can merge this pull request into a Git repository by running:
$ git pull ht
[
https://issues.apache.org/jira/browse/FLINK-5629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854366#comment-15854366
]
Ted Yu commented on FLINK-5629:
---
RandomAccessFile#length() may throw IOE.
raf is used in the
[
https://issues.apache.org/jira/browse/FLINK-5618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854369#comment-15854369
]
ASF GitHub Bot commented on FLINK-5618:
---
GitHub user NicoK opened a pull request:
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/3278
I don't think that you have at least once guarantees if you disable
flushing. Assume the following: You have the input `event1, checkpoint barrier,
event2`. Now you write `event1` to Kafka but i
[
https://issues.apache.org/jira/browse/FLINK-5701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854380#comment-15854380
]
ASF GitHub Bot commented on FLINK-5701:
---
Github user tillrohrmann commented on the i
Github user uce commented on the issue:
https://github.com/apache/flink/pull/3238
Could you please close this PR manually? Bot closing only works for the
master branch.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If
Github user uce commented on the issue:
https://github.com/apache/flink/pull/3241
Could you please close this PR manually? Bot closing only works for the
master branch.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If
[
https://issues.apache.org/jira/browse/FLINK-5575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854385#comment-15854385
]
ASF GitHub Bot commented on FLINK-5575:
---
Github user uce commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854382#comment-15854382
]
ASF GitHub Bot commented on FLINK-5575:
---
Github user uce commented on the issue:
Github user uce commented on the issue:
https://github.com/apache/flink/pull/3239
Could you please close this PR manually? Bot closing only works for the
master branch.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If
[
https://issues.apache.org/jira/browse/FLINK-5575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854384#comment-15854384
]
ASF GitHub Bot commented on FLINK-5575:
---
Github user uce commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854383#comment-15854383
]
ASF GitHub Bot commented on FLINK-5575:
---
Github user uce commented on the issue:
Github user uce commented on the issue:
https://github.com/apache/flink/pull/3240
Could you please close this PR manually? Bot closing only works for the
master branch.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If
[
https://issues.apache.org/jira/browse/FLINK-5575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-5575.
--
Resolution: Fixed
Fix Version/s: 1.2.0
1.1.5
1.3.0
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3242
---
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 is enab
[
https://issues.apache.org/jira/browse/FLINK-5575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854396#comment-15854396
]
ASF GitHub Bot commented on FLINK-5575:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-5564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854402#comment-15854402
]
Fabian Hueske commented on FLINK-5564:
--
Hi [~Shaoxuan Wang], I think it should be pos
[
https://issues.apache.org/jira/browse/FLINK-5564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854402#comment-15854402
]
Fabian Hueske edited comment on FLINK-5564 at 2/6/17 5:19 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-5701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854409#comment-15854409
]
ASF GitHub Bot commented on FLINK-5701:
---
Github user tzulitai commented on the issue
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/3278
@tillrohrmann
Yes, in the condition that you described, then at-least-once doesn't hold.
I said _might_ mainly considering there is chance that for every checkpoint
barrier, the previous events
[
https://issues.apache.org/jira/browse/FLINK-5618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854417#comment-15854417
]
ASF GitHub Bot commented on FLINK-5618:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3279
---
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 is enab
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/3249
@StephanEwen from the discussion of FLINK-3163 I also had the idea of
`taskmanager.compute.fraction` where the number of slots would be a multiple of
the number of cores / vcores. Since Flink proce
[
https://issues.apache.org/jira/browse/FLINK-3163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854437#comment-15854437
]
ASF GitHub Bot commented on FLINK-3163:
---
Github user greghogan commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-5488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-5488:
--
Description:
Here is one example:
{code}
if(jobManagerMemoryMb > maxRes.getMemory() ) {
failSessionDur
[
https://issues.apache.org/jira/browse/FLINK-5486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15822346#comment-15822346
]
Ted Yu edited comment on FLINK-5486 at 2/6/17 6:20 PM:
---
Lock on Stat
[
https://issues.apache.org/jira/browse/FLINK-5376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-5376:
--
Description:
The following are two examples where ordered stream element queue is mentioned:
{code}
LOG.
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/3274
you have to modify the corresponding jade files; modifications to the html
files will be overridden the next time someone builds the web-ui.
---
If your project is set up for it, you can reply to thi
[
https://issues.apache.org/jira/browse/FLINK-5723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854572#comment-15854572
]
ASF GitHub Bot commented on FLINK-5723:
---
Github user zentol commented on the issue:
Github user greghogan closed the pull request at:
https://github.com/apache/flink/pull/3247
---
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 is e
Github user greghogan closed the pull request at:
https://github.com/apache/flink/pull/3256
---
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 is e
[
https://issues.apache.org/jira/browse/FLINK-2883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854637#comment-15854637
]
ASF GitHub Bot commented on FLINK-2883:
---
Github user greghogan closed the pull reque
[
https://issues.apache.org/jira/browse/FLINK-5680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854636#comment-15854636
]
ASF GitHub Bot commented on FLINK-5680:
---
Github user greghogan closed the pull reque
[
https://issues.apache.org/jira/browse/FLINK-5680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan closed FLINK-5680.
-
Resolution: Implemented
1.2: 57cd0713183b4a2a2463736f672e1cd74cd913d6
master: 327ff060a7b64862aa6a33b6c8b0
[
https://issues.apache.org/jira/browse/FLINK-2883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan closed FLINK-2883.
-
Resolution: Implemented
1.2: 37d6f8196f12714491c95adb73319bb36e7a0d34
master: 11ebf484280314231d146dcfb0b9
Fokko Driesprong created FLINK-5724:
---
Summary: Error in the 'Zipping Elements' docs
Key: FLINK-5724
URL: https://issues.apache.org/jira/browse/FLINK-5724
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-3163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-3163:
--
Fix Version/s: 1.3.0
> Configure Flink for NUMA systems
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-2908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-2908:
--
Fix Version/s: 1.3.0
> Web interface redraw web plan when browser resized
>
GitHub user Fokko opened a pull request:
https://github.com/apache/flink/pull/3280
[Flink-5724] Error in documentation zipping elements
Because the Scala tab is defined twice, it is not possible to open
the Python tab.
Please look at the documentation page itself:
h
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/3276#discussion_r99674991
--- Diff: docs/setup/config.md ---
@@ -86,7 +86,7 @@ The default fraction for managed memory can be adjusted
using the `taskmanager.m
- `taskmana
[
https://issues.apache.org/jira/browse/FLINK-5718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854677#comment-15854677
]
ASF GitHub Bot commented on FLINK-5718:
---
Github user greghogan commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-5624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854818#comment-15854818
]
Haohui Mai commented on FLINK-5624:
---
Thanks for the explanation.
I took a closer look a
Haohui Mai created FLINK-5725:
-
Summary: Support JOIN between two streams in the SQL API
Key: FLINK-5725
URL: https://issues.apache.org/jira/browse/FLINK-5725
Project: Flink
Issue Type: New Featu
Github user haohui commented on the issue:
https://github.com/apache/flink/pull/3252
Updated the PR to recognize the `GROUP BY` clause instead of the `OVER`
clause.
---
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
[
https://issues.apache.org/jira/browse/FLINK-5624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854864#comment-15854864
]
ASF GitHub Bot commented on FLINK-5624:
---
Github user haohui commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854944#comment-15854944
]
Haohui Mai commented on FLINK-5583:
---
In general (1) sounds good to me. Taking a closer l
[
https://issues.apache.org/jira/browse/FLINK-5725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-5725:
---
Component/s: Table API & SQL
> Support JOIN between two streams in the SQL API
> -
Github user wangzhijiang999 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3151#discussion_r99731288
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMasterGateway.java
---
@@ -218,4 +218,12 @@ void failSlot(final ResourceI
[
https://issues.apache.org/jira/browse/FLINK-4364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855154#comment-15855154
]
ASF GitHub Bot commented on FLINK-4364:
---
Github user wangzhijiang999 commented on a
Github user wangzhijiang999 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3151#discussion_r99732047
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java
---
@@ -1058,6 +1092,30 @@ public void handleError(Thro
[
https://issues.apache.org/jira/browse/FLINK-4364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855166#comment-15855166
]
ASF GitHub Bot commented on FLINK-4364:
---
Github user wangzhijiang999 commented on a
Github user wangzhijiang999 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3151#discussion_r99732610
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java
---
@@ -1058,6 +1092,30 @@ public void handleError(Thro
[
https://issues.apache.org/jira/browse/FLINK-4364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855171#comment-15855171
]
ASF GitHub Bot commented on FLINK-4364:
---
Github user wangzhijiang999 commented on a
Github user wangzhijiang999 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3151#discussion_r99733319
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunner.java
---
@@ -112,6 +114,13 @@ public TaskManagerRunner(
[
https://issues.apache.org/jira/browse/FLINK-4364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855179#comment-15855179
]
ASF GitHub Bot commented on FLINK-4364:
---
Github user wangzhijiang999 commented on a
[
https://issues.apache.org/jira/browse/FLINK-4364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855194#comment-15855194
]
ASF GitHub Bot commented on FLINK-4364:
---
Github user wangzhijiang999 commented on a
Github user wangzhijiang999 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3151#discussion_r99734627
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java
---
@@ -741,6 +763,18 @@ private void establishJobManag
Github user liuyuzhong7 commented on the issue:
https://github.com/apache/flink/pull/3138
@StephanEwen What should to to with this pull request?
---
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 ha
Github user wangzhijiang999 commented on the issue:
https://github.com/apache/flink/pull/3151
@tillrohrmann . Thank you for detail review and comments!
This PR just submit the heartbeat logic in TM side, because there is
already a jira of JM heartbeat side.
For my imp
[
https://issues.apache.org/jira/browse/FLINK-4364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855207#comment-15855207
]
ASF GitHub Bot commented on FLINK-4364:
---
Github user wangzhijiang999 commented on th
Github user wangzhijiang999 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3151#discussion_r99736386
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java
---
@@ -126,6 +129,9 @@
/** The metric registry
[
https://issues.apache.org/jira/browse/FLINK-4364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855209#comment-15855209
]
ASF GitHub Bot commented on FLINK-4364:
---
Github user wangzhijiang999 commented on a
Github user wangzhijiang999 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2770#discussion_r99736682
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java
---
@@ -340,7 +344,8 @@ public RegistrationRespon
[
https://issues.apache.org/jira/browse/FLINK-4354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855212#comment-15855212
]
ASF GitHub Bot commented on FLINK-4354:
---
Github user wangzhijiang999 commented on a
Github user wangzhijiang999 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2770#discussion_r99737093
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java
---
@@ -137,6 +140,7 @@ public ResourceManager(
Github user wangzhijiang999 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2770#discussion_r99737151
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManagerGateway.java
---
@@ -122,4 +122,11 @@ void notifySlotAv
[
https://issues.apache.org/jira/browse/FLINK-4354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855216#comment-15855216
]
ASF GitHub Bot commented on FLINK-4354:
---
Github user wangzhijiang999 commented on a
[
https://issues.apache.org/jira/browse/FLINK-4354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855217#comment-15855217
]
ASF GitHub Bot commented on FLINK-4354:
---
Github user wangzhijiang999 commented on a
Github user wangzhijiang999 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2770#discussion_r99737204
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java
---
@@ -1099,4 +1121,23 @@ public void run() {
Github user wangzhijiang999 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2770#discussion_r99737255
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunner.java
---
@@ -99,6 +101,13 @@ public TaskManagerRunner(
[
https://issues.apache.org/jira/browse/FLINK-4354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855218#comment-15855218
]
ASF GitHub Bot commented on FLINK-4354:
---
Github user wangzhijiang999 commented on a
[
https://issues.apache.org/jira/browse/FLINK-4354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855222#comment-15855222
]
ASF GitHub Bot commented on FLINK-4354:
---
Github user wangzhijiang999 commented on a
Github user wangzhijiang999 commented on the issue:
https://github.com/apache/flink/pull/2770
@tillrohrmann , thank you for review!
Actually this PR is out-of-date based on flip-6, and my following
modifications do not update this PR. This PR should be re-submitted based on
m
[
https://issues.apache.org/jira/browse/FLINK-4354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855241#comment-15855241
]
ASF GitHub Bot commented on FLINK-4354:
---
Github user wangzhijiang999 commented on th
[
https://issues.apache.org/jira/browse/FLINK-5583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855251#comment-15855251
]
Tzu-Li (Gordon) Tai commented on FLINK-5583:
Hi [~wheat9],
I'm not quite sure
Longda Feng created FLINK-5726:
--
Summary: Add the RocketMQ plugin for the Apache Spark
Key: FLINK-5726
URL: https://issues.apache.org/jira/browse/FLINK-5726
Project: Flink
Issue Type: Task
[
https://issues.apache.org/jira/browse/FLINK-5726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Longda Feng updated FLINK-5726:
---
External issue ID: ROCKETMQ-82
> Add the RocketMQ plugin for the Apache Spark
> --
[
https://issues.apache.org/jira/browse/FLINK-5726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tao Meng updated FLINK-5726:
Summary: Add the RocketMQ plugin for the Apache Flink (was: Add the
RocketMQ plugin for the Apache Spark)
[
https://issues.apache.org/jira/browse/FLINK-5583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855313#comment-15855313
]
Tzu-Li (Gordon) Tai commented on FLINK-5583:
Regarding breaking user code when
[
https://issues.apache.org/jira/browse/FLINK-5704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855319#comment-15855319
]
Tzu-Li (Gordon) Tai commented on FLINK-5704:
FLINK-3679 and FLINK-5583 would p
[
https://issues.apache.org/jira/browse/FLINK-5702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855325#comment-15855325
]
Tzu-Li (Gordon) Tai commented on FLINK-5702:
[~StephanEwen] Good point about c
Kurt Young created FLINK-5727:
-
Summary: Unify some API of batch and stream TableEnvironment
Key: FLINK-5727
URL: https://issues.apache.org/jira/browse/FLINK-5727
Project: Flink
Issue Type: Impro
Github user ramkrish86 commented on the issue:
https://github.com/apache/flink/pull/3149
@fhueske - A gentle reminder !!!
---
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
201 - 300 of 323 matches
Mail list logo
