[
https://issues.apache.org/jira/browse/FLINK-7269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16104547#comment-16104547
]
ASF GitHub Bot commented on FLINK-7269:
---
Github user zjureel commented on the issue:
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 fr
[
https://issues.apache.org/jira/browse/FLINK-7269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16104545#comment-16104545
]
ASF GitHub Bot commented on FLINK-7269:
---
GitHub user zjureel opened a pull request:
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
co
[
https://issues.apache.org/jira/browse/FLINK-7269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fang Yong reassigned FLINK-7269:
Assignee: Fang Yong
> Refactor passing of dynamic properties
>
[
https://issues.apache.org/jira/browse/FLINK-7169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16104350#comment-16104350
]
ASF GitHub Bot commented on FLINK-7169:
---
Github user dianfu commented on the issue:
Github user dianfu commented on the issue:
https://github.com/apache/flink/pull/4331
Sorry for late response. I think this feature is very useful and agree that
we should have a clear thought on what things should be for each skip strategy.
I noticed that there are already some discus
[
https://issues.apache.org/jira/browse/FLINK-7169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16104311#comment-16104311
]
ASF GitHub Bot commented on FLINK-7169:
---
Github user yestinchen commented on the iss
Github user yestinchen commented on the issue:
https://github.com/apache/flink/pull/4331
@dawidwys Thanks for the reviewing.
Problem 1 is easy to fix, we can just start a new match process if the only
left computation state reaches stopState.
Problem 2 can not be avoided
[
https://issues.apache.org/jira/browse/FLINK-7179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16103533#comment-16103533
]
Shuyi Chen commented on FLINK-7179:
---
[~fhueske] I think the problem is in PushProjectInt
[
https://issues.apache.org/jira/browse/FLINK-7009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16103504#comment-16103504
]
ASF GitHub Bot commented on FLINK-7009:
---
Github user dbrinegar commented on the issu
Github user dbrinegar commented on the issue:
https://github.com/apache/flink/pull/4188
ping! let me know if any other changes are needed, 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 h
sk.exec(AbstractDispatcher.scala:397)
> at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
> at
> scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
> at
> scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
> at
> scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
> {code}
> https://s3.amazonaws.com/archive.travis-ci.org/jobs/258046274/log.txt?X-Amz-Expires=30&X-Amz-Date=20170727T12Z&X-Amz-Algorithm=AWS4-HMAC-SHA256&X-Amz-Credential=AKIAJRYRXRSVGNKPKO5A/20170727/us-east-1/s3/aws4_request&X-Amz-SignedHeaders=host&X-Amz-Signature=0b629a0c2b5daedc65c8aa8eb3293bc956f8fd61dc70066a051ed5878b004dbf
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
[
https://issues.apache.org/jira/browse/FLINK-7086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-7086.
Resolution: Done
Fix Version/s: 1.4.0
Added via 9af8036f3d42e6f4c2180e254e35faa8777e0292
> C
[
https://issues.apache.org/jira/browse/FLINK-7086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16103447#comment-16103447
]
ASF GitHub Bot commented on FLINK-7086:
---
Github user asfgit closed the pull request
GitHub user NicoK opened a pull request:
https://github.com/apache/flink/pull/4414
[FLINK-7287][tests] fix test instabilities in KafkaConsumerTestBase
## What is the purpose of the change
fix test instabilities in KafkaConsumerTestBase
## Brief change log
*
[
https://issues.apache.org/jira/browse/FLINK-7098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16103445#comment-16103445
]
ASF GitHub Bot commented on FLINK-7098:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4262
---
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-7098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-7098.
Resolution: Fixed
Fix Version/s: 1.4.0
Added via fa16e9a81517d216e7983caf425c84b1e2163b82
>
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4272
---
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-7115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-7115:
---
Labels: test-stability (was: )
> test instability in MiniClusterITCase.runJobWithMultipleJobManagers
$1(Future.scala:24)
> at
> scala.concurrent.impl.Future$PromiseCompletingRunnable.run(Future.scala:24)
> at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:40)
> at
> akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:3
4/log.txt?X-Amz-Expires=30&X-Amz-Date=20170727T12Z&X-Amz-Algorithm=AWS4-HMAC-SHA256&X-Amz-Credential=AKIAJRYRXRSVGNKPKO5A/20170727/us-east-1/s3/aws4_request&X-Amz-SignedHeaders=host&X-Amz-Signature=0b629a0c2b5daedc65c8aa8eb3293bc956f8fd61dc70066a051ed5878b004dbf
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
Elias Levy created FLINK-7286:
-
Summary: Flink Dashboard fails to display bytes/records received
by sources
Key: FLINK-7286
URL: https://issues.apache.org/jira/browse/FLINK-7286
Project: Flink
I
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/4280#discussion_r129881025
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java ---
@@ -478,12 +485,15 @@ public static void
runInteractiveCli(YarnC
[
https://issues.apache.org/jira/browse/FLINK-7125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16103378#comment-16103378
]
ASF GitHub Bot commented on FLINK-7125:
---
Github user pnowojski commented on a diff i
GitHub user StefanRRichter opened a pull request:
https://github.com/apache/flink/pull/4413
[BACKPORT-1.3][FLINK-7268] [checkpoints] Scope SharedStateRegistry objects
See #4410 . This is a bugfix backport from 1.4 to 1.3.x .
You can merge this pull request into a Git repository by r
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/4413
CC @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 and wishes so,
[
https://issues.apache.org/jira/browse/FLINK-6046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16103371#comment-16103371
]
ASF GitHub Bot commented on FLINK-6046:
---
GitHub user NicoK opened a pull request:
GitHub user NicoK opened a pull request:
https://github.com/apache/flink/pull/4412
[FLINK-6046][jobmanager] add support for oversized messages during
deployment
## What is the purpose of the change
This pull request makes big parts of the task deployment descriptor (TDD)
g
[
https://issues.apache.org/jira/browse/FLINK-7125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16103369#comment-16103369
]
ASF GitHub Bot commented on FLINK-7125:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4280#discussion_r129879671
--- Diff:
flink-yarn/src/test/java/org/apache/flink/yarn/YarnClusterDescriptorTest.java
---
@@ -210,6 +207,7 @@ public void testSetupApplicationMasterC
Github user StefanRRichter closed the pull request at:
https://github.com/apache/flink/pull/4411
---
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 StefanRRichter opened a pull request:
https://github.com/apache/flink/pull/4411
[BACKPORT-1.3] [FLINK-7268] [checkpoints] Scope SharedStateRegistry objects
per (re)start
See #4410. This is a bugfix backport from 1.4 to Flink 1.3.x .
You can merge this pull request into
[
https://issues.apache.org/jira/browse/FLINK-7125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16103365#comment-16103365
]
ASF GitHub Bot commented on FLINK-7125:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-7268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16103364#comment-16103364
]
ASF GitHub Bot commented on FLINK-7268:
---
Github user StefanRRichter commented on the
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/4410
CC @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 and wishes so,
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4280#discussion_r129878926
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClusterDescriptor.java
---
@@ -722,12 +697,30 @@ public ApplicationReport startApp
[
https://issues.apache.org/jira/browse/FLINK-7268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16103363#comment-16103363
]
ASF GitHub Bot commented on FLINK-7268:
---
GitHub user StefanRRichter opened a pull re
GitHub user StefanRRichter opened a pull request:
https://github.com/apache/flink/pull/4410
[FLINK-7268] [checkpoints] Scope SharedStateRegistry objects per (re)start
## What is the purpose of the change
This PR fixes FLINK-7268. The problem was that
`ZookeeperCompletedChec
[
https://issues.apache.org/jira/browse/FLINK-7125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16103361#comment-16103361
]
ASF GitHub Bot commented on FLINK-7125:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4280#discussion_r129878461
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClusterDescriptor.java
---
@@ -163,23 +161,17 @@ public AbstractYarnClusterDescrip
[
https://issues.apache.org/jira/browse/FLINK-7125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16103358#comment-16103358
]
ASF GitHub Bot commented on FLINK-7125:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4280#discussion_r129877902
--- Diff:
flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java ---
@@ -549,7 +559,12 @@ protected void runWithArgs(String[] args, Stri
Nico Kruber created FLINK-7285:
--
Summary: allow submission of big job graphs
Key: FLINK-7285
URL: https://issues.apache.org/jira/browse/FLINK-7285
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-7285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-7285:
---
Component/s: Network
> allow submission of big job graphs
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-7125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16103350#comment-16103350
]
ASF GitHub Bot commented on FLINK-7125:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4280#discussion_r129876779
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java ---
@@ -478,12 +485,15 @@ public static void
runInteractiveCli(Ya
[
https://issues.apache.org/jira/browse/FLINK-7125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16103347#comment-16103347
]
ASF GitHub Bot commented on FLINK-7125:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-7125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16103345#comment-16103345
]
ASF GitHub Bot commented on FLINK-7125:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-7125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16103341#comment-16103341
]
ASF GitHub Bot commented on FLINK-7125:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4280#discussion_r129875747
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnCLI.java ---
@@ -214,22 +218,21 @@ public void addGeneralOptions(Options baseOptio
[
https://issues.apache.org/jira/browse/FLINK-7125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16103344#comment-16103344
]
ASF GitHub Bot commented on FLINK-7125:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4280#discussion_r129875590
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnCLI.java ---
@@ -214,22 +218,21 @@ public void addGeneralOptions(Options baseOptio
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4280#discussion_r129875395
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/cli/DefaultCLI.java ---
@@ -77,10 +77,10 @@ public StandaloneClusterClient
retrieveCluste
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4280#discussion_r129875326
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/cli/DefaultCLI.java ---
@@ -58,7 +58,7 @@ public void addGeneralOptions(Options baseOption
[
https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16103282#comment-16103282
]
Xingcan Cui edited comment on FLINK-7245 at 7/27/17 3:18 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-7125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16103326#comment-16103326
]
ASF GitHub Bot commented on FLINK-7125:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4280#discussion_r129870736
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/cli/CustomCommandLine.java
---
@@ -62,25 +62,27 @@
* Retrieves a client for a ru
[
https://issues.apache.org/jira/browse/FLINK-7086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16103316#comment-16103316
]
ASF GitHub Bot commented on FLINK-7086:
---
Github user tillrohrmann commented on the i
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/4272
Thanks for the review @zentol. Rebasing this PR and merging once Travis
gives green light.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub
[
https://issues.apache.org/jira/browse/FLINK-7283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16103286#comment-16103286
]
ASF GitHub Bot commented on FLINK-7283:
---
GitHub user NicoK opened a pull request:
GitHub user NicoK opened a pull request:
https://github.com/apache/flink/pull/4409
[FLINK-7283][python] fix PythonPlanBinderTest issues with python paths
## What is the purpose of the change
Fix Python 2/3 path issues in `PythonPlanBinderTest`.
## Brief change log
[
https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16103282#comment-16103282
]
Xingcan Cui commented on FLINK-7245:
Hi [~fhueske], it took me a little time to compre
Till Rohrmann created FLINK-7284:
Summary: Verify compile time and runtime version of Hadoop
Key: FLINK-7284
URL: https://issues.apache.org/jira/browse/FLINK-7284
Project: Flink
Issue Type: I
Nico Kruber created FLINK-7283:
--
Summary: PythonPlanBinderTest issues with python paths
Key: FLINK-7283
URL: https://issues.apache.org/jira/browse/FLINK-7283
Project: Flink
Issue Type: Bug
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4380#discussion_r129837121
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeIdentitySortProcessFunctionOffsetFetch.scala
---
@@ -0
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4380#discussion_r129833188
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeIdentitySortProcessFunctionOffsetFetch.scala
---
@@ -0
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4380#discussion_r129821546
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamSort.scala
---
@@ -108,28 +108,25 @@ class DataS
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4380#discussion_r129833609
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeIdentitySortProcessFunctionOffsetFetch.scala
---
@@ -0
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4380#discussion_r129833309
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeIdentitySortProcessFunctionOffsetFetch.scala
---
@@ -0
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4380#discussion_r129832039
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeIdentitySortProcessFunctionOffsetFetch.scala
---
@@ -0
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4380#discussion_r129835046
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeIdentitySortProcessFunctionOffsetFetch.scala
---
@@ -0
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4380#discussion_r129827640
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/SortUtil.scala
---
@@ -75,12 +77,105 @@ object SortUtil {
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4380#discussion_r129838980
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamSort.scala
---
@@ -108,28 +108,25 @@ class DataS
[
https://issues.apache.org/jira/browse/FLINK-7147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16103180#comment-16103180
]
ASF GitHub Bot commented on FLINK-7147:
---
Github user dianfu commented on the issue:
Github user dianfu commented on the issue:
https://github.com/apache/flink/pull/4296
@dawidwys Thanks a lot for the review. I have updated the patch. Currently,
there is something wrong when the greedy state is followed by an optional
state. This can be covered by test case
GreedyITC
[
https://issues.apache.org/jira/browse/FLINK-7147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16103173#comment-16103173
]
ASF GitHub Bot commented on FLINK-7147:
---
Github user dianfu commented on a diff in t
Github user dianfu commented on a diff in the pull request:
https://github.com/apache/flink/pull/4296#discussion_r129832284
--- Diff:
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/GreedyITCase.java
---
@@ -0,0 +1,290 @@
+/*
+ * Licensed to the Apache Sof
[
https://issues.apache.org/jira/browse/FLINK-7147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16103164#comment-16103164
]
ASF GitHub Bot commented on FLINK-7147:
---
Github user dianfu commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-7169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16103166#comment-16103166
]
ASF GitHub Bot commented on FLINK-7169:
---
Github user dawidwys commented on the issue
Github user dawidwys commented on the issue:
https://github.com/apache/flink/pull/4331
Hi @yestinchen ,
Thanks for the update.
After second round of review. I found many problems with current approach.
It returns only the first match in a stream in most cases.
1.
[
https://issues.apache.org/jira/browse/FLINK-7147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16103165#comment-16103165
]
ASF GitHub Bot commented on FLINK-7147:
---
Github user dianfu commented on a diff in t
Github user dianfu commented on a diff in the pull request:
https://github.com/apache/flink/pull/4296#discussion_r129830324
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Quantifier.java
---
@@ -105,6 +107,14 @@ public void optional() {
Github user dianfu commented on a diff in the pull request:
https://github.com/apache/flink/pull/4296#discussion_r129830367
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Pattern.java
---
@@ -492,4 +506,10 @@ private void checkIfQuantifierApplied()
[
https://issues.apache.org/jira/browse/FLINK-6909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16103143#comment-16103143
]
Stephan Ewen commented on FLINK-6909:
-
I think Greg has a point here, but I also see t
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/4407#discussion_r129824759
--- Diff: tools/force-shading/pom.xml ---
@@ -93,11 +93,13 @@ under the License.
or
[
https://issues.apache.org/jira/browse/FLINK-7281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16103118#comment-16103118
]
ASF GitHub Bot commented on FLINK-7281:
---
Github user aljoscha commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16103120#comment-16103120
]
ASF GitHub Bot commented on FLINK-7281:
---
Github user aljoscha commented on a diff in
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/4407#discussion_r129824585
--- Diff: pom.xml ---
@@ -1246,14 +1247,32 @@ under the License.
org.apache.maven.p
[
https://issues.apache.org/jira/browse/FLINK-7281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16103116#comment-16103116
]
ASF GitHub Bot commented on FLINK-7281:
---
Github user aljoscha commented on a diff in
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/4407#discussion_r129824394
--- Diff: pom.xml ---
@@ -802,20 +802,6 @@ under the License.
[
https://issues.apache.org/jira/browse/FLINK-7281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16103115#comment-16103115
]
ASF GitHub Bot commented on FLINK-7281:
---
Github user aljoscha commented on a diff in
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/4407#discussion_r129824175
--- Diff: pom.xml ---
@@ -1257,6 +1243,17 @@ under the License.
+
+
[
https://issues.apache.org/jira/browse/FLINK-7282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-7282:
Description:
This is a part of work for network stack improvements proposed in
[~StephanEwen] 's
[FLIP|ht
[
https://issues.apache.org/jira/browse/FLINK-7282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-7282:
Description:
This is a part of work for network stack improvements proposed in
[~StephanEwen] 's
[FLIP|ht
[
https://issues.apache.org/jira/browse/FLINK-7282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-7282:
Description:
This is a part of work for network stack improvements proposed in
[~StephanEwen] 's
[FLIP|ht
[
https://issues.apache.org/jira/browse/FLINK-7282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-7282:
Description:
This is a part of work for network stack improvements proposed in
[~StephanEwen] 's
[FLIP|ht
zhijiang created FLINK-7282:
---
Summary: Credit-based Network Flow Control
Key: FLINK-7282
URL: https://issues.apache.org/jira/browse/FLINK-7282
Project: Flink
Issue Type: New Feature
Compo
[
https://issues.apache.org/jira/browse/FLINK-7281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16103050#comment-16103050
]
ASF GitHub Bot commented on FLINK-7281:
---
Github user zentol commented on a diff in t
1 - 100 of 148 matches
Mail list logo
