GitHub user vrozov opened a pull request:
https://github.com/apache/apex-site/pull/76
Changed default mail archive to mailing list from mod_mbox
@tweise Please review
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vrozov/apex
GitHub user vrozov opened a pull request:
https://github.com/apache/apex-core/pull/553
APEXCORE-753 Add mailing lists, SCM and issue tracking information to POM
@tweise Please review and merge
You can merge this pull request into a Git repository by running:
$ git pull https
GitHub user vrozov opened a pull request:
https://github.com/apache/apex-core/pull/550
APEXCORE-747 Provide additional ToStringStyle options
@PramodSSImmaneni Please review
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vrozov
GitHub user vrozov opened a pull request:
https://github.com/apache/apex-core/pull/549
APEXCORE-749 Fix README.md formatting
@tweise Please review
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vrozov/apex-core APEXCORE-749
GitHub user vrozov opened a pull request:
https://github.com/apache/apex-core/pull/548
APEXCORE-748 Upgrade netlet dependency to 1.3.2
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vrozov/apex-core APEXCORE-748
Alternatively
GitHub user vrozov reopened a pull request:
https://github.com/apache/apex-core/pull/542
APEXCORE-745 Buffer server may stop processing tuples when backpressure is
enabled
@PramodSSImmaneni, @sandeshh Please review
You can merge this pull request into a Git repository by running
Github user vrozov closed the pull request at:
https://github.com/apache/apex-core/pull/542
---
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
Github user vrozov closed the pull request at:
https://github.com/apache/apex-core/pull/533
---
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
GitHub user vrozov reopened a pull request:
https://github.com/apache/apex-core/pull/533
APEXCORE-735 Upgrade maven-dependency-plugin
@tweise @PramodSSImmaneni Please review
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vrozov
Github user vrozov closed the pull request at:
https://github.com/apache/apex-core/pull/533
---
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
GitHub user vrozov reopened a pull request:
https://github.com/apache/apex-core/pull/533
APEXCORE-735 Upgrade maven-dependency-plugin
@tweise @PramodSSImmaneni Please review
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vrozov
Github user vrozov closed the pull request at:
https://github.com/apache/apex-core/pull/533
---
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
GitHub user vrozov reopened a pull request:
https://github.com/apache/apex-core/pull/533
APEXCORE-735 Upgrade maven-dependency-plugin
@tweise @PramodSSImmaneni Please review
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vrozov
Github user vrozov closed the pull request at:
https://github.com/apache/apex-core/pull/533
---
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
GitHub user vrozov reopened a pull request:
https://github.com/apache/apex-core/pull/533
APEXCORE-735 Upgrade maven-dependency-plugin
@tweise @PramodSSImmaneni Please review
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vrozov
Github user vrozov closed the pull request at:
https://github.com/apache/apex-core/pull/533
---
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
GitHub user vrozov reopened a pull request:
https://github.com/apache/apex-core/pull/533
APEXCORE-735 Upgrade maven-dependency-plugin
@tweise @PramodSSImmaneni Please review
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vrozov
GitHub user vrozov opened a pull request:
https://github.com/apache/apex-core/pull/542
APEXCORE-745 Buffer server may stop processing tuples when backpressure is
enabled
@PramodSSImmaneni, @sandeshh Please review
You can merge this pull request into a Git repository by running
GitHub user vrozov opened a pull request:
https://github.com/apache/apex-core/pull/537
APEXCORE-741 Upgrade netlet dependency to 1.3.1
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vrozov/apex-core APEXCORE-741
Alternatively
GitHub user vrozov opened a pull request:
https://github.com/apache/apex-core/pull/533
APEXCORE-735 Upgrade maven-dependency-plugin
@tweise @PramodSSImmaneni Please review
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vrozov
GitHub user vrozov opened a pull request:
https://github.com/apache/apex-core/pull/532
APEXCORE-734 StramLocalCluster may not terminate properly
@PramodSSImmaneni @tweise Please review
You can merge this pull request into a Git repository by running:
$ git pull https
GitHub user vrozov opened a pull request:
https://github.com/apache/apex-core/pull/524
APEXCORE-717 Remove unnecessary archetypeVersion property
@tweise Please see.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vrozov/apex-core
GitHub user vrozov opened a pull request:
https://github.com/apache/apex-core/pull/521
APEXCORE-715 Remove unnecessary @Evolving annotation in engine
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vrozov/apex-core APEXCORE-715
GitHub user vrozov opened a pull request:
https://github.com/apache/apex-core/pull/516
APEXCORE-703 Window processing timeout for finished/undeployed container.
During an operator shutdown, mark it as INACTIVE to exclude it from the
blocked operators check.
@tweise Please
GitHub user vrozov opened a pull request:
https://github.com/apache/apex-core/pull/506
APEXCORE-695 Remove unnecessary interface modifiers
@tweise Please merge
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vrozov/apex-core
GitHub user vrozov opened a pull request:
https://github.com/apache/apex-core/pull/505
APEXCORE-691 Use type inference for generic instance creation
@tweise Please merge
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vrozov/apex
GitHub user vrozov opened a pull request:
https://github.com/apache/apex-core/pull/502
APEXCORE-686 AppPackage fails when .apa contains zero length stored entry
@PramodSSImmaneni Please review
You can merge this pull request into a Git repository by running:
$ git pull https
GitHub user vrozov opened a pull request:
https://github.com/apache/apex-core/pull/496
APEXCORE-683 Apex client should support application packages on HDFS
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vrozov/apex-core
GitHub user vrozov opened a pull request:
https://github.com/apache/apex-core/pull/492
APEXCORE-677 Avoid starting StramLocalCluster in
StreamingContainerManagerTest.testAppDataSources
@tweise Please merge
You can merge this pull request into a Git repository by running
Github user vrozov closed the pull request at:
https://github.com/apache/apex-core/pull/481
---
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
GitHub user vrozov opened a pull request:
https://github.com/apache/apex-malhar/pull/580
APEXMALHAR-2306 Tests should allow for additions to OperatorContext
interface
@tweise Please review
You can merge this pull request into a Git repository by running:
$ git pull https
GitHub user vrozov opened a pull request:
https://github.com/apache/apex-core/pull/481
APEXCORE-656 Upgrade org.apache.httpcomponents.httpclient.
@PramodSSImmaneni please review and merge
You can merge this pull request into a Git repository by running:
$ git pull https
GitHub user vrozov opened a pull request:
https://github.com/apache/apex-core/pull/477
APEXCORE-648 Unnecessary byte array copy in
DefaultStatefulStreamCodec.toDataStatePair()
@sandeshh Please review and merge
You can merge this pull request into a Git repository by running
GitHub user vrozov opened a pull request:
https://github.com/apache/apex-core/pull/472
APEXCORE-645 StramLocalCluster does not wait for master thread termination
@tweise or @PramodSSImmaneni please merge
You can merge this pull request into a Git repository by running:
$ git
GitHub user vrozov opened a pull request:
https://github.com/apache/apex-core/pull/471
APEXCORE-597 BufferServer needs to shutdown all created execution services
@PramodSSImmaneni, @tweise, @tushargosavi or @sandeshh Please review
You can merge this pull request into a Git
GitHub user vrozov opened a pull request:
https://github.com/apache/apex-core/pull/470
APEXCORE-641 Subscribers/DataListeners may not be scheduled to execute even
when they have data to process
@PramodSSImmaneni, @tweise, @sandeshh Please review.
You can merge this pull request
GitHub user vrozov opened a pull request:
https://github.com/apache/apex-core/pull/461
APEXCORE-504 - Possible race condition in
StreamingContainerAgent.getStreamCodec()
@PramodSSImmaneni or @tweise Please review
You can merge this pull request into a Git repository by running
GitHub user vrozov opened a pull request:
https://github.com/apache/apex-core/pull/451
APEXCORE-617 InputNodeTest intermittently fails with
ConcurrentModificationException
@ilooner or @PramodSSImmaneni Please review
You can merge this pull request into a Git repository by running
GitHub user vrozov opened a pull request:
https://github.com/apache/apex-core/pull/449
Set right margin to 120. Do not wrap long lines.
@davidyan74 Please merge
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vrozov/apex-core
GitHub user vrozov opened a pull request:
https://github.com/apache/apex-core/pull/448
APEXCORE-608 Streaming Containers use stale RPC proxy after connection is
closed
@tweise Please review
You can merge this pull request into a Git repository by running:
$ git pull https
GitHub user vrozov opened a pull request:
https://github.com/apache/apex-core/pull/444
APEXCORE-605 Suppress bootstrap compiler warning
@tweise Please review
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vrozov/apex-core
GitHub user vrozov opened a pull request:
https://github.com/apache/apex-core/pull/438
APEXCORE-504 - Possible race condition in
StreamingContainerAgent.getStreamCodec()
@PramodSSImmaneni, @tweise Please review and merge.
You can merge this pull request into a Git repository by
GitHub user vrozov opened a pull request:
https://github.com/apache/apex-core/pull/436
APEXCORE-456 - Explicitly limit Server.Subscriber to one way communication
@PramodSSImmaneni Please review
You can merge this pull request into a Git repository by running:
$ git pull https
GitHub user vrozov opened a pull request:
https://github.com/apache/apex-core/pull/434
APEXCORE-591 - SubscribeRequestTuple has wrong buffer size when mask is zero
@tushargosavi Please review
You can merge this pull request into a Git repository by running:
$ git pull https
GitHub user vrozov opened a pull request:
https://github.com/apache/apex-core/pull/431
Add Apache 2.0 license to META-INF/services files
@PramodSSImmaneni Please merge
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vrozov/apex
GitHub user vrozov opened a pull request:
https://github.com/apache/apex-core/pull/428
APEXCORE-583 - Buffer Server LogicalNode should not be reused by Subscribers
@PramodSSImmaneni, @tweise, @243826 Please review.
You can merge this pull request into a Git repository by running
GitHub user vrozov opened a pull request:
https://github.com/apache/apex-core/pull/420
APEXCORE-456 - Explicitly limit Server.Subscriber to one way communication
@PramodSSImmaneni Please review only.
You can merge this pull request into a Git repository by running:
$ git pull
GitHub user vrozov opened a pull request:
https://github.com/apache/apex-core/pull/419
APEXCORE-251 - Suppress "Journal output stream is null..." warning in unit
tests
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/v
GitHub user vrozov opened a pull request:
https://github.com/apache/apex-core/pull/418
APEXCORE-557 - Upgrade netlet dependency to 1.3.0
@PramodSSImmaneni please merge
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vrozov/apex
GitHub user vrozov opened a pull request:
https://github.com/apache/apex-core/pull/415
APEXCORE-572 - Remove dependency on hadoop-common test.jar
@PramodSSImmaneni, @tweise Please review
You can merge this pull request into a Git repository by running:
$ git pull https
GitHub user vrozov opened a pull request:
https://github.com/apache/apex-site/pull/51
Mentioned enforcing no trailing whitespaces by checkstyle.
@tweise Please review
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vrozov/apex
GitHub user vrozov opened a pull request:
https://github.com/apache/apex-core/pull/396
APEXCORE-538 - Log raw data when RPC message fails to de-serialize
@tweise Please review and cherry-pick.
You can merge this pull request into a Git repository by running:
$ git pull https
GitHub user vrozov opened a pull request:
https://github.com/apache/apex-core/pull/392
APEXCORE-535 - Node.teardown() should try to gracefully shutdown exectutor
service
@tweise, @PramodSSImmaneni Please review.
You can merge this pull request into a Git repository by running
GitHub user vrozov opened a pull request:
https://github.com/apache/apex-core/pull/389
APEXCORE-531 - Enable System.out/System.err check for *Test
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vrozov/apex-core APEXCORE-531
GitHub user vrozov opened a pull request:
https://github.com/apache/apex-core/pull/388
APEXCORE-527 - Minor changes in LocalStramChildLauncher to help with unit
test failures
@tweise Please review
You can merge this pull request into a Git repository by running:
$ git pull
Github user vrozov closed the pull request at:
https://github.com/apache/apex-core/pull/385
---
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
GitHub user vrozov reopened a pull request:
https://github.com/apache/apex-core/pull/385
APEXCORE-522 - Promote singleton usage pattern for String2String,
Long2String and other StringCodecs
You can merge this pull request into a Git repository by running:
$ git pull https
GitHub user vrozov opened a pull request:
https://github.com/apache/apex-core/pull/386
APEXCORE-524 - Add support for custom maven repository to
ClassPathResolverTest.testManifestClassPathResolver
@tweise Please review
You can merge this pull request into a Git repository by
GitHub user vrozov opened a pull request:
https://github.com/apache/apex-core/pull/385
APEXCORE-522 - Promote singleton usage pattern for String2String,
Long2String and other StringCodecs
You can merge this pull request into a Git repository by running:
$ git pull https
Github user vrozov closed the pull request at:
https://github.com/apache/apex-core/pull/384
---
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
GitHub user vrozov opened a pull request:
https://github.com/apache/apex-core/pull/384
APEXCORE-521 upate parent pom references.
test Apache Jenkins PR build. Please don't merge.
You can merge this pull request into a Git repository by running:
$ git pull https://githu
GitHub user vrozov opened a pull request:
https://github.com/apache/apex-core/pull/379
APEXCORE-518 - Update codestyle-config project pom.xml
@tweise Please pull in after #367
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
GitHub user vrozov opened a pull request:
https://github.com/apache/apex-core/pull/376
APEXCORE-516 - StramLocalCluster should always use loopback address for
buffer server location
@tweise Please review
You can merge this pull request into a Git repository by running:
$ git
GitHub user vrozov opened a pull request:
https://github.com/apache/apex-core/pull/375
APEXCORE-169 - instantiating DTLoggerFactory during test causes incorrect
logging behavior
@tweise, @chandnisingh Please review
You can merge this pull request into a Git repository by running
GitHub user vrozov opened a pull request:
https://github.com/apache/apex-core/pull/370
APEXCORE-502 Unnecessary byte array copy in
DefaultKryoStreamCodec.toByteArray
@tweise Please review
You can merge this pull request into a Git repository by running:
$ git pull https
GitHub user vrozov opened a pull request:
https://github.com/apache/apex-core/pull/367
APEXCORE-506 Added check for trailing whitespaces
@tweise, @chandnisingh Please review
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vrozov
Github user vrozov commented on the issue:
https://github.com/apache/apex-core/pull/364
As far as I can see not all changes are correct (please see my comments
regarding UnifierDeployInfo and access from two different threads to the
operatorName). It will be good to have them fixed
Github user vrozov commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/364#discussion_r73454311
--- Diff:
engine/src/main/java/com/datatorrent/stram/engine/StreamingContainer.java ---
@@ -902,14 +902,14 @@ private void deployNodes(List
nodeList
Github user vrozov commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/364#discussion_r73454152
--- Diff:
engine/src/test/java/com/datatorrent/stram/engine/OperatorContextTest.java ---
@@ -0,0 +1,99 @@
+/**
+ * Licensed to the Apache Software
Github user vrozov commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/364#discussion_r73453695
--- Diff:
engine/src/test/java/com/datatorrent/stram/engine/OperatorContextTest.java ---
@@ -0,0 +1,112 @@
+/**
+ * Licensed to the Apache Software
Github user vrozov commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/364#discussion_r73451447
--- Diff:
engine/src/test/java/com/datatorrent/stram/engine/OperatorContextTest.java ---
@@ -0,0 +1,112 @@
+/**
+ * Licensed to the Apache Software
Github user vrozov commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/364#discussion_r73450932
--- Diff:
engine/src/test/java/com/datatorrent/stram/engine/OperatorContextTest.java ---
@@ -0,0 +1,99 @@
+/**
+ * Licensed to the Apache Software
Github user vrozov commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/364#discussion_r73450445
--- Diff:
engine/src/main/java/com/datatorrent/stram/engine/StreamingContainer.java ---
@@ -902,14 +902,14 @@ private void deployNodes(List
nodeList
Github user vrozov commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/364#discussion_r73449937
--- Diff:
engine/src/main/java/com/datatorrent/stram/engine/StreamingContainer.java ---
@@ -902,14 +902,14 @@ private void deployNodes(List
nodeList
Github user vrozov commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/364#discussion_r73448436
--- Diff:
engine/src/test/java/com/datatorrent/stram/engine/OperatorContextTest.java ---
@@ -0,0 +1,99 @@
+/**
+ * Licensed to the Apache Software
Github user vrozov commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/364#discussion_r73445463
--- Diff:
engine/src/test/java/com/datatorrent/stram/engine/OperatorContextTest.java ---
@@ -0,0 +1,99 @@
+/**
+ * Licensed to the Apache Software
Github user vrozov commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/364#discussion_r73437878
--- Diff:
engine/src/main/java/com/datatorrent/stram/engine/OperatorContext.java ---
@@ -84,12 +87,13 @@ public void setIdleTimeout(long idleTimeout
Github user vrozov commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/364#discussion_r73431751
--- Diff:
engine/src/main/java/com/datatorrent/stram/engine/OperatorContext.java ---
@@ -84,12 +87,13 @@ public void setIdleTimeout(long idleTimeout
Github user vrozov commented on the issue:
https://github.com/apache/apex-core/pull/343
@chandnisingh changes for IntelliJ looks good to me. Can you please review
other IDE and merge if they look good to you.
---
If your project is set up for it, you can reply to this email and have
Github user vrozov commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/364#discussion_r73426924
--- Diff:
engine/src/main/java/com/datatorrent/stram/engine/OperatorContext.java ---
@@ -84,12 +87,13 @@ public void setIdleTimeout(long idleTimeout
Github user vrozov commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/364#discussion_r73425701
--- Diff:
engine/src/main/java/com/datatorrent/stram/engine/OperatorContext.java ---
@@ -84,12 +87,13 @@ public void setIdleTimeout(long idleTimeout
Github user vrozov commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/364#discussion_r73423271
--- Diff:
engine/src/test/java/com/datatorrent/stram/engine/OperatorContextTest.java ---
@@ -0,0 +1,99 @@
+/**
+ * Licensed to the Apache Software
Github user vrozov commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/364#discussion_r73365188
--- Diff:
engine/src/test/java/com/datatorrent/stram/engine/OperatorContextTest.java ---
@@ -0,0 +1,99 @@
+/**
+ * Licensed to the Apache Software
Github user vrozov commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/364#discussion_r73068052
--- Diff:
engine/src/main/java/com/datatorrent/stram/engine/OperatorContext.java ---
@@ -84,12 +87,13 @@ public void setIdleTimeout(long idleTimeout
Github user vrozov commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/364#discussion_r73066955
--- Diff:
engine/src/main/java/com/datatorrent/stram/engine/OperatorContext.java ---
@@ -84,12 +87,13 @@ public void setIdleTimeout(long idleTimeout
Github user vrozov commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/364#discussion_r73066772
--- Diff: api/src/main/java/com/datatorrent/api/Context.java ---
@@ -328,6 +328,8 @@
*/
int getWindowsFromCheckpoint
Github user vrozov commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/364#discussion_r73065873
--- Diff: api/src/main/java/com/datatorrent/api/Context.java ---
@@ -328,6 +328,8 @@
*/
int getWindowsFromCheckpoint
Github user vrozov commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/358#discussion_r72615867
--- Diff:
engine/src/main/java/com/datatorrent/stram/plan/physical/PTOperator.java ---
@@ -85,6 +85,7 @@
private static final long
Github user vrozov commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/359#discussion_r71945201
--- Diff:
engine/src/main/java/com/datatorrent/stram/plan/physical/PhysicalPlan.java ---
@@ -895,8 +895,10 @@ private void redoPartitions(PMapping
Github user vrozov commented on the issue:
https://github.com/apache/apex-core/pull/359
@chaithu14 Please close this PR and open a new one once the issue is fixed.
---
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 vrozov commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/361#discussion_r71943358
--- Diff: api/src/main/java/com/datatorrent/api/StatsListener.java ---
@@ -113,6 +113,8 @@
long getLatencyMA();
List
Github user vrozov commented on the issue:
https://github.com/apache/apex-core/pull/358
Most of the time default unifier (the one that passes tuples unmodified
from input streams to an output stream) is used. For that case, it is necessary
to benchmark the change (please see my
Github user vrozov commented on the issue:
https://github.com/apache/apex-core/pull/359
@chaithu14 As @amberarrow mentioned, definePartitions() may return superset
or subset of current partitions. The bug seems to be in the redeploying
dependencies, not in the modified code that
Github user vrozov commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/359#discussion_r71816678
--- Diff:
engine/src/main/java/com/datatorrent/stram/plan/physical/PhysicalPlan.java ---
@@ -895,8 +895,10 @@ private void redoPartitions(PMapping
Github user vrozov commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/359#discussion_r71801328
--- Diff:
engine/src/main/java/com/datatorrent/stram/plan/physical/PhysicalPlan.java ---
@@ -895,8 +895,10 @@ private void redoPartitions(PMapping
Github user vrozov commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/359#discussion_r71744011
--- Diff:
engine/src/main/java/com/datatorrent/stram/plan/physical/PhysicalPlan.java ---
@@ -895,8 +895,10 @@ private void redoPartitions(PMapping
Github user vrozov commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/359#discussion_r71728748
--- Diff:
engine/src/main/java/com/datatorrent/stram/plan/physical/PhysicalPlan.java ---
@@ -895,8 +895,10 @@ private void redoPartitions(PMapping
Github user vrozov commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/359#discussion_r71721012
--- Diff:
engine/src/main/java/com/datatorrent/stram/plan/physical/PhysicalPlan.java ---
@@ -895,8 +895,10 @@ private void redoPartitions(PMapping
Github user vrozov commented on the issue:
https://github.com/apache/apex-core/pull/358
What is the reason unifier does not have it's own StreamMeta? IMO, it will
be better to introduce separate StreamMeta for unifiers instead of the locality
field that is used only for uni
Github user vrozov commented on the issue:
https://github.com/apache/apex-core/pull/358
TODO: provide benchmark numbers for 4, 16, 32 and possibly 64 unifiers
comparing existing behavior with behavior after the commit.
---
If your project is set up for it, you can reply to this
1 - 100 of 142 matches
Mail list logo
